diff --git a/src/parallel.jl b/src/parallel.jl index 9072eb0..449a36b 100644 --- a/src/parallel.jl +++ b/src/parallel.jl @@ -223,7 +223,7 @@ function Base.put!(f!, ringbuffer::RingBuffer) return buf_ end -Base.put!(::Channel{T}, ::MLUtils.RingBuffer) = error("method not defined for RingBuffer") +Base.put!(c::Channel{T}, b::MLUtils.RingBuffer) = throw(MethodError(put!, (c, b))) function Base.close(ringbuffer::RingBuffer, args...) close(ringbuffer.results, args...)