chore: remove unascessary function

Author: Adriano Santos

lib/grpc/stream.ex

@@ -119,28 +119,6 @@ defmodule GRPC.Stream do
   def unary(input, opts \\ []) when is_struct(input),
     do: build_grpc_stream([input], Keyword.merge(opts, unary: true))
 
-  @doc """
-  Wraps an existing `Flow` into a `GRPC.Stream` struct.
-
-  > Note: `:join_with` is not supported in this mode and will raise an error if passed.
-
-  ## Parameters
-
-    - `flow`: A valid `Flow` pipeline.
-
-  ## Returns
-
-    A `%GRPC.Stream{}` struct wrapping the flow.
-  """
-  @spec from_flow!(Flow.t(), Keyword.t()) :: t()
-  def from_flow!(%Flow{} = flow, opts \\ []) do
-    if Keyword.has_key?(opts, :join_with) do
-      raise ArgumentError, "join_with option is not supported for Flow input"
-    end
-
-    %__MODULE__{flow: flow, options: opts}
-  end
-
   @doc """
   Extracts the internal `Flow` pipeline from a `GRPC.Stream`.
 

test/grpc/stream_test.exs

@@ -74,15 +74,6 @@ defmodule GRPC.StreamTest do
       result = stream |> GRPC.Stream.map(&(&1 * 2)) |> GRPC.Stream.to_flow() |> Enum.to_list()
       assert Enum.sort(result) == [2, 4, 6]
     end
-
-    test "converts from Flow to GRPC.Stream" do
-      flow = Flow.from_enumerable([1, 2, 3], max_demand: 1)
-      stream = GRPC.Stream.from_flow!(flow)
-      assert %GRPC.Stream{flow: ^flow} = stream
-
-      result = stream |> GRPC.Stream.map(&(&1 * 2)) |> GRPC.Stream.to_flow() |> Enum.to_list()
-      assert Enum.sort(result) == [2, 4, 6]
-    end
   end
 
   describe "ask/3 with pid" do