We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c9830a commit 1374ee1Copy full SHA for 1374ee1
gst-plugin-pravega/src/pravegasrc/imp.rs
@@ -163,6 +163,7 @@ enum State {
163
Started {
164
reader: Arc<Mutex<CountingReader<BufReader<SeekableTake<SyncByteReader>>>>>,
165
index_searcher: Arc<Mutex<IndexSearcher<SyncByteReader>>>,
166
+ // save client facotry to keep the tokio runtime
167
client_factory: ClientFactory,
168
},
169
}
@@ -680,7 +681,6 @@ impl BaseSrcImpl for PravegaSrc {
680
681
*state = State::Started {
682
reader: Arc::new(Mutex::new(counting_reader)),
683
index_searcher: Arc::new(Mutex::new(index_searcher)),
- // save client facotry to keep the tokio runtime
684
client_factory,
685
};
686
gst_info!(CAT, obj: element, "start: Started");
0 commit comments