Skip to content

Commit 2568127

Browse files
committed
Merge branch 'master' into allow-format-changes
2 parents ec923a4 + 61a5ef4 commit 2568127

File tree

6 files changed

+24
-24
lines changed

6 files changed

+24
-24
lines changed

Diff for: README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ The package can be installed by adding `membrane_transcoder_plugin` to your list
1717
```elixir
1818
def deps do
1919
[
20-
{:membrane_transcoder_plugin, "~> 0.1.4"}
20+
{:membrane_transcoder_plugin, "~> 0.2.0"}
2121
]
2222
end
2323
```

Diff for: lib/transcoder.ex

+8-8
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ defmodule Membrane.Transcoder do
6969
and is supposed to return the desired output stream format or its module.
7070
"""
7171
],
72-
enforce_transcoding?: [
72+
force_transcoding?: [
7373
spec: boolean() | (stream_format() -> boolean()),
7474
default: false,
7575
description: """
@@ -109,16 +109,16 @@ defmodule Membrane.Transcoder do
109109
|> resolve_output_stream_format()
110110

111111
state =
112-
with %{enforce_transcoding?: f} when is_function(f) <- state do
113-
%{state | enforce_transcoding?: f.(format)}
112+
with %{force_transcoding?: f} when is_function(f) <- state do
113+
%{state | force_transcoding?: f.(format)}
114114
end
115115

116116
spec =
117117
get_child(:connector)
118118
|> plug_transcoding(
119119
format,
120120
state.output_stream_format,
121-
state.enforce_transcoding?
121+
state.force_transcoding?
122122
)
123123
|> get_child(:output_funnel)
124124

@@ -160,15 +160,15 @@ defmodule Membrane.Transcoder do
160160
end
161161
end
162162

163-
defp plug_transcoding(builder, input_format, output_format, enforce_transcoding?)
163+
defp plug_transcoding(builder, input_format, output_format, force_transcoding?)
164164
when Audio.is_audio_format(input_format) do
165165
builder
166-
|> Audio.plug_audio_transcoding(input_format, output_format, enforce_transcoding?)
166+
|> Audio.plug_audio_transcoding(input_format, output_format, force_transcoding?)
167167
end
168168

169-
defp plug_transcoding(builder, input_format, output_format, enforce_transcoding?)
169+
defp plug_transcoding(builder, input_format, output_format, force_transcoding?)
170170
when Video.is_video_format(input_format) do
171171
builder
172-
|> Video.plug_video_transcoding(input_format, output_format, enforce_transcoding?)
172+
|> Video.plug_video_transcoding(input_format, output_format, force_transcoding?)
173173
end
174174
end

Diff for: lib/transcoder/audio.ex

+5-5
Original file line numberDiff line numberDiff line change
@@ -35,16 +35,16 @@ defmodule Membrane.Transcoder.Audio do
3535
audio_stream_format(),
3636
boolean()
3737
) :: ChildrenSpec.builder()
38-
def plug_audio_transcoding(builder, input_format, output_format, enforce_transcoding?)
38+
def plug_audio_transcoding(builder, input_format, output_format, force_transcoding?)
3939
when is_audio_format(input_format) and is_audio_format(output_format) do
40-
do_plug_audio_transcoding(builder, input_format, output_format, enforce_transcoding?)
40+
do_plug_audio_transcoding(builder, input_format, output_format, force_transcoding?)
4141
end
4242

4343
defp do_plug_audio_transcoding(
4444
builder,
4545
%format_module{},
4646
%format_module{},
47-
false = _enforce_transcoding?
47+
false = _force_transcoding?
4848
) do
4949
Membrane.Logger.debug("""
5050
This bin will only forward buffers, as the input stream format is the same as the output stream format.
@@ -57,12 +57,12 @@ defmodule Membrane.Transcoder.Audio do
5757
builder,
5858
%RemoteStream{content_format: Opus},
5959
%Opus{},
60-
false = _enforce_transcoding?
60+
false = _force_transcoding?
6161
) do
6262
builder |> child(:opus_parser, Opus.Parser)
6363
end
6464

65-
defp do_plug_audio_transcoding(builder, input_format, output_format, _enforce_transcoding?) do
65+
defp do_plug_audio_transcoding(builder, input_format, output_format, _force_transcoding?) do
6666
builder
6767
|> maybe_plug_parser(input_format)
6868
|> maybe_plug_decoder(input_format)

Diff for: lib/transcoder/video.ex

+5-5
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,16 @@ defmodule Membrane.Transcoder.Video do
1919
video_stream_format(),
2020
boolean()
2121
) :: ChildrenSpec.builder()
22-
def plug_video_transcoding(builder, input_format, output_format, enforce_transcoding?)
22+
def plug_video_transcoding(builder, input_format, output_format, force_transcoding?)
2323
when is_video_format(input_format) and is_video_format(output_format) do
24-
do_plug_video_transcoding(builder, input_format, output_format, enforce_transcoding?)
24+
do_plug_video_transcoding(builder, input_format, output_format, force_transcoding?)
2525
end
2626

2727
defp do_plug_video_transcoding(
2828
builder,
2929
%h26x{},
3030
%h26x{} = output_format,
31-
false = _enforce_transcoding?
31+
false = _force_transcoding?
3232
)
3333
when h26x in [H264, H265] do
3434
parser =
@@ -46,7 +46,7 @@ defmodule Membrane.Transcoder.Video do
4646
builder,
4747
%format_module{},
4848
%format_module{},
49-
false = _enforce_transcoding?
49+
false = _force_transcoding?
5050
) do
5151
Membrane.Logger.debug("""
5252
This bin will only forward buffers, as the input stream format is the same type as the output stream format.
@@ -55,7 +55,7 @@ defmodule Membrane.Transcoder.Video do
5555
builder
5656
end
5757

58-
defp do_plug_video_transcoding(builder, input_format, output_format, _enforce_transcoding?) do
58+
defp do_plug_video_transcoding(builder, input_format, output_format, _force_transcoding?) do
5959
builder
6060
|> maybe_plug_parser_and_decoder(input_format)
6161
|> maybe_plug_encoder_and_parser(output_format)

Diff for: mix.exs

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
defmodule Membrane.Transcoder.Plugin.Mixfile do
22
use Mix.Project
33

4-
@version "0.1.4"
4+
@version "0.2.0"
55
@github_url "https://github.com/membraneframework/membrane_transcoder_plugin"
66

77
def project do

Diff for: test/integration_test.exs

+4-4
Original file line numberDiff line numberDiff line change
@@ -67,14 +67,14 @@ defmodule Membrane.Transcoder.IntegrationTest do
6767
do: {[stream_format: {:output, state.format}], state}
6868
end
6969

70-
test "if encoder and decoder are spawned or not, depending on the value of `enforce_transcoding?` option" do
70+
test "if encoder and decoder are spawned or not, depending on the value of `force_transcoding?` option" do
7171
for format <- [%AAC{channels: 1}, %H264{alignment: :au, stream_structure: :annexb}],
72-
enforce_transcoding? <- [true, false] do
72+
force_transcoding? <- [true, false] do
7373
spec =
7474
child(:source, %FormatSource{format: format})
7575
|> child(:transcoder, %Membrane.Transcoder{
7676
output_stream_format: format,
77-
enforce_transcoding?: enforce_transcoding?
77+
force_transcoding?: force_transcoding?
7878
})
7979
|> child(:sink, Testing.Sink)
8080

@@ -89,7 +89,7 @@ defmodule Membrane.Transcoder.IntegrationTest do
8989
|> Enum.each(fn child_name ->
9090
get_child_result = Testing.Pipeline.get_child_pid(pipeline, [:transcoder, child_name])
9191

92-
if enforce_transcoding? do
92+
if force_transcoding? do
9393
assert {:ok, child_pid} = get_child_result
9494
assert is_pid(child_pid)
9595
else

0 commit comments

Comments
 (0)