Skip to content

Commit

Permalink
docs: fix Rx.using/UsingStream docs
Browse files Browse the repository at this point in the history
  • Loading branch information
hoc081098 committed Apr 2, 2024
1 parent 1d8eeb5 commit f009156
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions lib/src/streams/using.dart
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,9 @@ import 'dart:async';
/// ### Example
///
/// UsingStream<int, Queue<int>>(
/// () => Queue.of([1, 2, 3]),
/// (r) => Stream.fromIterable(r),
/// (r) => r.clear(),
/// resourceFactory: () => Queue.of([1, 2, 3]),
/// streamFactory: (r) => Stream.fromIterable(r),
/// disposer: (r) => r.clear(),
/// ).listen(print); // prints 1, 2, 3
class UsingStream<T, R> extends StreamView<T> {
/// Construct a [UsingStream] that creates a resource object from [resourceFactory],
Expand Down

0 comments on commit f009156

Please sign in to comment.