diff options
| author | Rubens Brandao <git@rubens.io> | 2021-04-05 18:50:58 +0200 |
|---|---|---|
| committer | Rubens Brandao <git@rubens.io> | 2021-04-05 18:50:58 +0200 |
| commit | 38270c4a2374c2ccc04597a28fb191af9d86b814 (patch) | |
| tree | 831dd65d5a5bda3aba3633fbfe6d7af1449c38d9 /mumd/src/network | |
| parent | e431ecb6c5c8406bde6a54f40ee2f648cc0cec05 (diff) | |
| download | mum-38270c4a2374c2ccc04597a28fb191af9d86b814.tar.gz | |
Rename audio functions and basic indentation
Diffstat (limited to 'mumd/src/network')
| -rw-r--r-- | mumd/src/network/tcp.rs | 2 | ||||
| -rw-r--r-- | mumd/src/network/udp.rs | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/mumd/src/network/tcp.rs b/mumd/src/network/tcp.rs index d2f0b41..1414318 100644 --- a/mumd/src/network/tcp.rs +++ b/mumd/src/network/tcp.rs @@ -108,7 +108,7 @@ pub async fn handle( let password = state_lock.password().map(|x| x.to_string()); authenticate(&mut sink, username, password).await?; let phase_watcher = state_lock.phase_receiver(); - let input_receiver = state_lock.audio_input().input_receiver(); + let input_receiver = state_lock.audio_input().receiver(); drop(state_lock); let event_queue = TcpEventQueue::new(); diff --git a/mumd/src/network/udp.rs b/mumd/src/network/udp.rs index a8e190d..8614358 100644 --- a/mumd/src/network/udp.rs +++ b/mumd/src/network/udp.rs @@ -33,7 +33,7 @@ pub async fn handle( mut connection_info_receiver: watch::Receiver<Option<ConnectionInfo>>, mut crypt_state_receiver: mpsc::Receiver<ClientCryptState>, ) -> Result<(), UdpError> { - let receiver = state.lock().await.audio_input().input_receiver(); + let receiver = state.lock().await.audio_input().receiver(); loop { let connection_info = 'data: loop { |
