Comparing version
@@ -95,2 +95,6 @@ #! /usr/bin/env node | ||
const executeInput = childMessages | ||
.filter(msg => msg.header.msg_type === 'execute_input') | ||
.map(msg => msg.content); | ||
const executeReply = childMessages | ||
@@ -110,2 +114,3 @@ .filter(msg => msg.header.msg_type === 'execute_reply') | ||
.map(msg => msg.content); | ||
const errorStream = Rx.Observable | ||
@@ -155,3 +160,3 @@ .merge(errorReplies, executeReply.filter(x => x.status === 'error')); | ||
Rx.Observable.merge(executeResult, executeReply) | ||
Rx.Observable.merge(executeResult, executeReply, executeInput) | ||
.map(content => content.execution_count) | ||
@@ -158,0 +163,0 @@ .take(1) |
{ | ||
"name": "ick", | ||
"version": "0.2.0", | ||
"version": "0.2.1", | ||
"description": "Interactive Console Experiment", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
10548
1.9%164
1.86%