docs: fix Rx.using/UsingStream docs (#752)

* docs: fix `Rx.using`/`UsingStream` docs * Update rx.dart
ReactiveX · Apr 2, 2024 · 8134a51 · 8134a51
1 parent 1d8eeb5
commit 8134a51
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/lib/src/rx.dart b/lib/src/rx.dart
@@ -965,9 +965,9 @@ abstract class Rx {
   /// ### Example
   ///
   ///     Rx.using<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
   static Stream<T> using<T, R>({
     required FutureOr<R> Function() resourceFactory,

diff --git a/lib/src/streams/using.dart b/lib/src/streams/using.dart
@@ -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],