-
Notifications
You must be signed in to change notification settings - Fork 2
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add Source Dispatcher #17
Conversation
lib/agora/agora_dispatcher.ex
Outdated
def_input_pad(:input, | ||
flow_control: :auto, | ||
accepted_format: _any | ||
) | ||
|
||
def_output_pad(:output, | ||
flow_control: :auto, | ||
accepted_format: _any, | ||
availability: :on_request | ||
) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
- auto is the default
- add accepted format
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
lib/agora/agora_dispatcher.ex
Outdated
if user_id in Map.keys(state.output_pads) do | ||
{[], state} | ||
else | ||
add_pad(state, user_id) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why do we send the add_pad
notification from handle_pad_added
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I've fixed that
lib/agora/agora_dispatcher.ex
Outdated
@@ -0,0 +1,91 @@ | |||
defmodule Membrane.Agora.Dispatcher do | |||
@moduledoc false |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This should be either used somewhere or documented for public use ;) Also, tests are missing
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I have added the documentation and the tests, but as you know there are problems with running these integration tests :/
…echanism to the test.
…. Add ORB circle ci config
… the dispatcher when the dispatcher is already running
This PR:
Membrane.Agora.Dispatcher
capable of dispatching the stream output by theMembrane.Agora.Source
based on theuser_id
field from the buffers metadata