We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3b6fda3 commit e843a97Copy full SHA for e843a97
sensors/transports/tinkerforge.py
@@ -115,7 +115,7 @@ def _stream_transport(transport: TinkerforgeTransport):
115
stream.call(transport.enumerate) | pipe.filter(lambda x: False), # drop the result, because we don't care
116
stream.iterate(transport.read_enumeration())
117
| pipe.action(transport.notify_device) # Notify clients to shut down if necessary
118
- | pipe.filter(transport.filter_enumerations) # Only proceed with if the client is not yet created
+ | pipe.filter(transport.filter_enumerations) # Only proceed if the client is not yet created
119
| pipe.starmap(lambda enumeration_type, sensor: TinkerforgeSensor(sensor))
120
| pipe.map(lambda sensor: sensor.stream_data())
121
| pipe.flatten(),
0 commit comments