fix messenger eltype
This commit is contained in:
parent
a18c7d36d0
commit
987d2840da
1 changed files with 2 additions and 3 deletions
|
@ -465,7 +465,7 @@ struct Messenger{Sample, Scribe, Input, Output}
|
||||||
output_channel::Channel{Output}
|
output_channel::Channel{Output}
|
||||||
end
|
end
|
||||||
|
|
||||||
eltype(::Type{Messenger{Sample}}) where {Sample} = Sample
|
eltype(::Type{<: Messenger{Sample}}) where {Sample} = Sample
|
||||||
name(messenger::Messenger) = messenger.device_name
|
name(messenger::Messenger) = messenger.device_name
|
||||||
nchannels(messenger::Messenger) = nchannels(messenger.buffer)
|
nchannels(messenger::Messenger) = nchannels(messenger.buffer)
|
||||||
|
|
||||||
|
@ -535,9 +535,8 @@ function fetch_messenger(messenger, task)
|
||||||
# wait for tasks to finish to make sure any errors get caught
|
# wait for tasks to finish to make sure any errors get caught
|
||||||
wait(task)
|
wait(task)
|
||||||
# output channel will close because it is bound to the task
|
# output channel will close because it is bound to the task
|
||||||
else
|
|
||||||
""
|
|
||||||
end
|
end
|
||||||
|
nothing
|
||||||
end
|
end
|
||||||
|
|
||||||
#
|
#
|
||||||
|
|
Loading…
Reference in a new issue