1
2
3
4
5
6
7
8
9
10
11
12
13
14

use crate::ConnectionMultiplexer;

#[derive(Clone)]
pub struct PubSub {
    pub(crate) multiplexer: ConnectionMultiplexer,
}

impl PubSub {
    pub(crate) fn new(multiplexer: ConnectionMultiplexer) -> Self {
        Self {
            multiplexer,
        }
    }
}