View Source Membrane.RCPipeline (Membrane Core v1.1.0)
Remote controlled pipeline - a basic Membrane.Pipeline implementation that can be remotely controlled from an external process.
The easiest way to start this pipeline is to use start_link!/1
pipeline = Membrane.RCPipeline.start_link!()The controlling process can request the execution of arbitrary
valid Membrane.Pipeline.Action:
children = ...
links = ...
actions = [{:spec, children++links}]
Pipeline.exec_actions(pipeline, actions)The controlling process can also subscribe to the messages sent by the pipeline and later on synchronously await for these messages:
# subscribes to message which is sent when the pipeline enters `playing`
Membrane.RCPipeline.subscribe(pipeline, %Message.Playing{})
...
# awaits for the message sent when the pipeline enters :playing playback
Membrane.RCPipeline.await_playing(pipeline)
...Membrane.RCPipeline can be used when there is no need for introducing a custom
logic in the Membrane.Pipeline callbacks implementation. An example of usage could be running a
pipeline from the elixir script. Membrane.RCPipeline sends the following messages:
Membrane.RCMessage.Playing.t/0sent when pipeline entersplayingplayback,Membrane.RCMessage.StartOfStream.t/0sent when one of direct pipeline children informs the pipeline about start of a stream,Membrane.RCMessage.EndOfStream.t/0sent when one of direct pipeline children informs the pipeline about end of a stream,Membrane.RCMessage.Notification.t/0sent when pipeline receives notification from one of its children,Membrane.RCMessage.Terminated.t/0sent when the pipeline gracefully terminates.
Summary
Functions
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.EndOfStream.t/0 message
with no further constraints, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.EndOfStream.t/0 message
concerning the given element, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.EndOfStream.t/0 message
concerning the given element and the pad, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Notification.t/0
message with no further constraints, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Notification.t/0 message
concerning the given element, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Playing.t/0
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.StartOfStream.t/0 message
with no further constraints, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.StartOfStream.t/0 message
concerning the given element, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.StartOfStream.t/0 message
concerning the given element and the pad, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Awaits for the Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Terminated message,
which is send when the pipeline gracefully terminates.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Returns child specification for spawning under a supervisor
Sends a list of t:Pipeline.Action.t/0 to the given Membrane.RCPipeline for execution.
Does the same as the start_link/1 but starts the process outside of the current supervision tree.
Starts the Membrane.RCPipeline and links it to the current process. The process
that makes the call to the start_link/1 automatically becomes the controller process.
Subscribes to a given subscription_pattern. The subscription_pattern should describe some subset
of elements of t:Membrane.RCPipeline.Message.t/0 type. The subscription_pattern
must be a match pattern.
Functions
@spec await_end_of_stream(pid()) :: Membrane.RCMessage.EndOfStream.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.EndOfStream.t/0 message
with no further constraints, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first
end_of_streamoccuring on any pad of any element in the pipeline:Pipeline.await_end_of_stream(pipeline)
@spec await_end_of_stream(pid(), Membrane.Element.name()) :: Membrane.RCMessage.EndOfStream.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.EndOfStream.t/0 message
concerning the given element, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first
end_of_streamoccuring on any pad of the:element_idelement in the pipeline:Pipeline.await_end_of_stream(pipeline, :element_id)
@spec await_end_of_stream(pid(), Membrane.Element.name(), Membrane.Pad.name()) :: Membrane.RCMessage.EndOfStream.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.EndOfStream.t/0 message
concerning the given element and the pad, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first
end_of_streamoccuring on the:pad_idof the:element_idelement in the pipeline:Pipeline.await_end_of_stream(pipeline, :element_id, :pad_id)
@spec await_notification(pid()) :: Membrane.RCMessage.Notification.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Notification.t/0
message with no further constraints, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first notification send to any element in the pipeline:
Pipeline.await_notification(pipeline)
@spec await_notification(pid(), Membrane.ParentNotification.t()) :: Membrane.RCMessage.Notification.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Notification.t/0 message
concerning the given element, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first notification send to the
:element_idelement in the pipeline:Pipeline.await_notification(pipeline, :element_id)
@spec await_playing(pid()) :: Membrane.RCMessage.Playing.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Playing.t/0
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting until the pipeline starts playing:
Pipeline.await_playing(pipeline)
@spec await_start_of_stream(pid()) :: Membrane.RCMessage.StartOfStream.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.StartOfStream.t/0 message
with no further constraints, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first
start_of_streamoccuring on any pad of any element in the pipeline:Pipeline.await_start_of_stream(pipeline)
@spec await_start_of_stream(pid(), Membrane.Element.name()) :: Membrane.RCMessage.StartOfStream.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.StartOfStream.t/0 message
concerning the given element, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first
start_of_streamoccuring on any pad of the:element_idelement in the pipeline:Pipeline.await_start_of_stream(pipeline, :element_id)
@spec await_start_of_stream(pid(), Membrane.Element.name(), Membrane.Pad.name()) :: Membrane.RCMessage.StartOfStream.t()
Awaits for the first Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.StartOfStream.t/0 message
concerning the given element and the pad, sent by the process with pipeline pid.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the first
start_of_streamoccuring on the:pad_idpad of the:element_idelement in the pipeline:Pipeline.await_start_of_stream(pipeline, :element_id, :pad_id)
@spec await_termination(pid()) :: Membrane.RCMessage.Terminated.t()
Awaits for the Membrane.RCMessage.t/0 wrapping the Membrane.RCMessage.Terminated message,
which is send when the pipeline gracefully terminates.
It is required to firstly use the subscribe/2 to subscribe to a given message before awaiting
for that message.
Usage example:
- awaiting for the pipeline termination:
Pipeline.await_termination(pipeline)
Returns child specification for spawning under a supervisor
@spec exec_actions(pid(), [Membrane.Pipeline.Action.t()]) :: :ok
Sends a list of t:Pipeline.Action.t/0 to the given Membrane.RCPipeline for execution.
Usage example:
- making the
Membrane.RCPipelinestart theMembrane.ChildrenSpecspecified in the action.children = ... links = ... actions = [{:spec, children++links}] Pipeline.exec_actions(pipeline, actions)
@spec start([Membrane.Pipeline.config_entry() | {:controller_pid, pid()}]) :: Membrane.Pipeline.on_start()
Does the same as the start_link/1 but starts the process outside of the current supervision tree.
@spec start!([Membrane.Pipeline.config_entry() | {:controller_pid, pid()}]) :: pid()
@spec start_link([Membrane.Pipeline.config_entry() | {:controller_pid, pid()}]) :: Membrane.Pipeline.on_start()
Starts the Membrane.RCPipeline and links it to the current process. The process
that makes the call to the start_link/1 automatically becomes the controller process.
@spec start_link!([Membrane.Pipeline.config_entry() | {:controller_pid, pid()}]) :: pid()
Subscribes to a given subscription_pattern. The subscription_pattern should describe some subset
of elements of t:Membrane.RCPipeline.Message.t/0 type. The subscription_pattern
must be a match pattern.
Usage examples:
- making the
Membrane.RCPipelinesend to the controlling processMessage.StartOfStreammessage when any pad of the:element_idreceives:start_of_streamevent.
subscribe(pipeline, %Message.StartOfStream{element: :element_id, pad: _})- making the
Membrane.RCPipelinesend to the controlling processMessage.Playingmessage when the pipeline playback changes to:playing
subscribe(pipeline, %Message.Playing{})