ProxyStream<T> constructor

ProxyStream<T>({
  1. required DBusRemoteObjectSignalStream stream,
  2. required T mapFunction(
    1. DBusSignal
    ),
})

Implementation

ProxyStream({required DBusRemoteObjectSignalStream stream, required T Function(DBusSignal) mapFunction}):
_originalStream = stream,
_mappedStream = stream.asBroadcastStream().map(mapFunction);