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.
2 parents 7d56965 + a635b1f commit 359d751Copy full SHA for 359d751
lib/src/core/implementation/thing_discovery.dart
@@ -358,16 +358,6 @@ extension _UriExtension on Uri {
358
}
359
360
361
-/// Extension to simplify the handling of nested [Stream]s.
362
-extension _FlatStreamExtension<T> on Stream<Stream<T>> {
363
- /// Flattens a nested [Stream] of [Stream]s into a single [Stream].
364
- Stream<T> flatten() async* {
365
- await for (final stream in this) {
366
- yield* stream;
367
- }
368
369
-}
370
-
371
/// Implemention of the [scripting_api.ThingDiscoveryProcess] interface.
372
class ThingDiscoveryProcess extends Stream<ThingDescription>
373
implements scripting_api.ThingDiscoveryProcess {
0 commit comments