forked from the-distro/ofborg
Update ofborg/src/easylapin.rs
Co-authored-by: Cole Helbling <cole.e.helbling@outlook.com>
This commit is contained in:
parent
f652901df2
commit
b6e870f5cb
|
@ -115,8 +115,8 @@ impl<'a, W: SimpleWorker + 'a> ConsumerExt<'a, W> for CloseOnDrop<Channel> {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Same as a regular channel, but without prefetching,
|
/// Same as a regular channel, but without prefetching,
|
||||||
// used for services with multiple instances.
|
/// used for services with multiple instances.
|
||||||
pub struct WorkerChannel(pub CloseOnDrop<Channel>);
|
pub struct WorkerChannel(pub CloseOnDrop<Channel>);
|
||||||
|
|
||||||
impl<'a, W: SimpleWorker + 'a> ConsumerExt<'a, W> for WorkerChannel {
|
impl<'a, W: SimpleWorker + 'a> ConsumerExt<'a, W> for WorkerChannel {
|
||||||
|
|
Loading…
Reference in a new issue