fix(types): resolve Steep type checking errors

- Make train_batch params nilable (?(Type)? syntax) in all classifiers
- Add _StreamingHost interface for Streaming module dependencies
- Fix TFIDF stub methods with proper RBS and steep:ignore
- Make Matrix/Vector non-generic in vendor RBS
- Add Enumerable type param to LineReader

Author: cardmagic

lib/classifier/bayes.rb

@@ -354,7 +354,7 @@ def train_from_stream(category, io, batch_size: Streaming::DEFAULT_BATCH_SIZE)
     #     puts "#{progress.percent}% complete"
     #   end
     #
-    # @rbs (?(String | Symbol), ?Array[String], ?batch_size: Integer, **Array[String]) { (Streaming::Progress) -> void } -> void
+    # @rbs (?(String | Symbol)?, ?Array[String]?, ?batch_size: Integer, **Array[String]) { (Streaming::Progress) -> void } -> void
     def train_batch(category = nil, documents = nil, batch_size: Streaming::DEFAULT_BATCH_SIZE, **categories, &block)
       if category && documents
         train_batch_for_category(category, documents, batch_size: batch_size, &block)

lib/classifier/logistic_regression.rb

@@ -399,7 +399,7 @@ def train_from_stream(category, io, batch_size: Streaming::DEFAULT_BATCH_SIZE)
     #   classifier.train_batch(spam: documents, ham: other_docs)
     #   classifier.fit
     #
-    # @rbs (?(String | Symbol), ?Array[String], ?batch_size: Integer, **Array[String]) { (Streaming::Progress) -> void } -> void
+    # @rbs (?(String | Symbol)?, ?Array[String]?, ?batch_size: Integer, **Array[String]) { (Streaming::Progress) -> void } -> void
     def train_batch(category = nil, documents = nil, batch_size: Streaming::DEFAULT_BATCH_SIZE, **categories, &block)
       if category && documents
         train_batch_for_category(category, documents, batch_size: batch_size, &block)

lib/classifier/lsi.rb

@@ -709,7 +709,7 @@ def add_batch(batch_size: Streaming::DEFAULT_BATCH_SIZE, **items)
     # Alias train_batch to add_batch for API consistency with other classifiers.
     # Note: LSI uses categories differently (items have categories, not the training call).
     #
-    # @rbs (?(String | Symbol), ?Array[String], ?batch_size: Integer, **Array[String]) { (Streaming::Progress) -> void } -> void
+    # @rbs (?(String | Symbol)?, ?Array[String]?, ?batch_size: Integer, **Array[String]) { (Streaming::Progress) -> void } -> void
     def train_batch(category = nil, documents = nil, batch_size: Streaming::DEFAULT_BATCH_SIZE, **categories, &block)
       if category && documents
         add_batch(batch_size: batch_size, **{ category.to_sym => documents }, &block)

lib/classifier/streaming.rb

@@ -40,7 +40,7 @@ def train_from_stream(category, io, batch_size: DEFAULT_BATCH_SIZE, &block)
     # @example Keyword style
     #   classifier.train_batch(spam: documents, ham: other_docs, batch_size: 100)
     #
-    # @rbs (?(Symbol | String), ?Array[String], ?batch_size: Integer, **Array[String]) { (Progress) -> void } -> void
+    # @rbs (?(Symbol | String)?, ?Array[String]?, ?batch_size: Integer, **Array[String]) { (Progress) -> void } -> void
     def train_batch(category = nil, documents = nil, batch_size: DEFAULT_BATCH_SIZE, **categories, &block)
       raise NotImplementedError, "#{self.class} must implement train_batch"
     end

lib/classifier/tfidf.rb

@@ -299,16 +299,16 @@ def fit_from_stream(io, batch_size: Streaming::DEFAULT_BATCH_SIZE)
     # TFIDF doesn't support train_from_stream (use fit_from_stream instead).
     # This method raises NotImplementedError with guidance.
     #
-    # @rbs (untyped, untyped, **untyped) -> void
-    def train_from_stream(*)
+    # @rbs (*untyped, **untyped) -> void
+    def train_from_stream(*) # steep:ignore
       raise NotImplementedError, 'TFIDF uses fit_from_stream instead of train_from_stream'
     end
 
     # TFIDF doesn't support train_batch (use fit instead).
     # This method raises NotImplementedError with guidance.
     #
-    # @rbs (**untyped) -> void
-    def train_batch(*)
+    # @rbs (*untyped, **untyped) -> void
+    def train_batch(*) # steep:ignore
       raise NotImplementedError, 'TFIDF uses fit instead of train_batch'
     end
 

sig/vendor/streaming.rbs

@@ -0,0 +1,14 @@
+# Type stubs for Streaming module
+# Defines the interface that including classes must implement
+
+module Classifier
+  # Interface for classes that include Streaming
+  interface _StreamingHost
+    def storage: () -> Storage::Base?
+    def storage=: (Storage::Base?) -> void
+    def save: () -> void
+  end
+
+  module Streaming : _StreamingHost
+  end
+end