Skip to content

Commit a635b1f

Browse files
committed
refactor: remove obsolete _FlatStreamExtension
1 parent 7d56965 commit a635b1f

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

lib/src/core/implementation/thing_discovery.dart

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -358,16 +358,6 @@ extension _UriExtension on Uri {
358358
}
359359
}
360360

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-
371361
/// Implemention of the [scripting_api.ThingDiscoveryProcess] interface.
372362
class ThingDiscoveryProcess extends Stream<ThingDescription>
373363
implements scripting_api.ThingDiscoveryProcess {

0 commit comments

Comments
 (0)