In [1]:

    

from bsread import source


    

In [2]:

    

with source('sf-lc', 7777) as stream:
    for i in range(10):
        message = stream.receive()
        print(message)


    

    




<mflow.mflow.Message object at 0x1090deac8>
<mflow.mflow.Message object at 0x1090e9940>
<mflow.mflow.Message object at 0x1090deac8>
<mflow.mflow.Message object at 0x1090e9940>
<mflow.mflow.Message object at 0x1090deac8>
<mflow.mflow.Message object at 0x1090f1da0>
<mflow.mflow.Message object at 0x1090deac8>
<mflow.mflow.Message object at 0x10445fda0>
<mflow.mflow.Message object at 0x1090deac8>
<mflow.mflow.Message object at 0x1090f1cf8>

In [2]:

    

from bsread import source
import bsread


    

In [ ]:

    

with source(channels=['UInt16Waveform'], dispatcher_url='http://localhost:8080') as stream:
    for i in range(10):
        message = stream.receive()
        print(message)


    

    




[mflow.mflow][WARNING] Unable to decode message - skipping






    




<mflow.mflow.Message object at 0x1094b5be0>

In [ ]: