From f90faf3100f8bf00b701307107c081f3fb5928e6 Mon Sep 17 00:00:00 2001
From: mcmah309 <dillonmcmahon79@gmail.com>
Date: Tue, 12 Mar 2024 11:49:54 +0000
Subject: [PATCH] feat: Better type safety on Connect

---
 packages/signals_core/lib/src/async/connect.dart | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/packages/signals_core/lib/src/async/connect.dart b/packages/signals_core/lib/src/async/connect.dart
index 8c35ef02..6cb4e15e 100644
--- a/packages/signals_core/lib/src/async/connect.dart
+++ b/packages/signals_core/lib/src/async/connect.dart
@@ -48,7 +48,7 @@ import '../core/signals.dart';
 /// ```
 /// @link https://dartsignals.dev/dart/async/connect
 /// {@endtemplate}
-class Connect<T> {
+class Connect<T, S extends T> {
   /// Connects a [Stream] to a [Signal].
   Connect(this.signal);
 
@@ -69,8 +69,8 @@ class Connect<T> {
   ///
   /// c.dispose();
   /// ```
-  Connect<T> from(
-    Stream<T> source, {
+  Connect<T,S> from(
+    Stream<S> source, {
     bool? cancelOnError,
     Function? onError,
     Function? onDone,
@@ -97,7 +97,7 @@ class Connect<T> {
   }
 
   /// Synonym for `from(Stream<T> source)`
-  Connect<T> operator <<(Stream<T> source) => from(source);
+  Connect<T,S> operator <<(Stream<S> source) => from(source);
 
   /// Cancels all subscriptions.
   void dispose() {
@@ -155,8 +155,8 @@ class Connect<T> {
 /// ```
 /// @link https://dartsignals.dev/dart/async/connect
 /// {@endtemplate}
-Connect<T> connect<T>(Signal<T> signal, [Stream<T>? stream]) {
-  final instance = Connect(signal);
+Connect<T,S> connect<T,S extends T>(Signal<T> signal, [Stream<S>? stream]) {
+  final instance = Connect<T,S>(signal);
   if (stream != null) instance << stream;
   return instance;
 }
\ No newline at end of file