Substreams and scalar example

streamy.coffee

c = new noflo.Component
  inPorts:
    streamy:
      datatype: 'object'
      description: 'Substreams'
    inty:
      datatype: 'int'
      description: 'Scalar'
  outPorts:
    result:
      datatype: 'object'
c.process (input, output) ->
  if input.has 'streamy'
    s = input.get 'streamy'
    switch s.type
      when 'openBracket'
        c.streamy = [ s.data ]
        c.streamyComplete = false
      when 'data'
        c.streamy.push s.data
      when 'closeBracket'
        c.streamyComplete = true
  if input.has 'inty' and c.streamyComplete
    i = input.getData 'inty'
    res = doSomething c.streamy, i
    c.streamyComplete = false
    output.sendDone
      result: res