Open mat-hek opened 1 week ago
The plugin should contain elements that would
input = Stream.cycle([1, 2, 3]) output = Membrane.Elixir.Stream.new() p = Membrane.RCPipeline.start_link!() Membrane.RCPipeline.exec_actions(spec: child(%Membrane.Elixir.Source{input: input}) |> child(%Membrane.Elixir.Sink{output: output}) ) output |> Stream.map(& &1 + 1) |> Enum.take(3) # => [2, 3, 4]
Possibly it should end up in the core.
The plugin should contain elements that would
Possibly it should end up in the core.