Skip to content

Instantly share code, notes, and snippets.

@smaldini
Created July 29, 2014 16:56
Show Gist options
  • Save smaldini/630fd0e3de1a8a637124 to your computer and use it in GitHub Desktop.
Save smaldini/630fd0e3de1a8a637124 to your computer and use it in GitHub Desktop.
{
"id": "Stream",
"to": [
{
"bound-to": [
{
"id": "1",
"to": [
{
"id": "Callback",
"info": "{dispatcher=Synchronous, state=COMPLETE, max-capacity=2147483643, subscription={capacity=2147483640, buffered=0}, pending=2147483643, currentNextSignals=3}"
}
],
"info": "Stream{state=COMPLETE, keepAlive=false}{key=1}"
},
{
"id": "2",
"to": [
{
"id": "Callback",
"info": "{dispatcher=Synchronous, state=COMPLETE, max-capacity=2147483643, subscription={capacity=2147483642, buffered=0}, pending=2147483643, currentNextSignals=1}"
}
],
"info": "Stream{state=COMPLETE, keepAlive=false}{key=2}"
},
{
"id": "3",
"to": [
{
"id": "Callback",
"info": "{dispatcher=Synchronous, state=COMPLETE, max-capacity=2147483643, subscription={capacity=2147483641, buffered=0}, pending=2147483643, currentNextSignals=2}"
}
],
"info": "Stream{state=COMPLETE, keepAlive=false}{key=3}"
}
],
"id": "GroupBy",
"to": [
{
"id": "Callback",
"info": "{dispatcher=Synchronous, state=COMPLETE, max-capacity=2147483647, subscription={firehose!}, pending=0, currentNextSignals=3}"
}
],
"info": "{dispatcher=Synchronous, state=COMPLETE, max-capacity=2147483643, subscription={capacity=2147483637, buffered=0}, pending=2147483647, currentNextSignals=6}"
}
],
"info": "Stream{state=COMPLETE, keepAlive=true}"
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment