|
@@ -97,34 +97,5 @@ void main() {
|
|
|
expect(fakeAudio.isRecording, false);
|
|
expect(fakeAudio.isRecording, false);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
- test('sends audio chunks while recording', () async {
|
|
|
|
|
- fakeAudio.chunkData = 'Zm9v';
|
|
|
|
|
- await container.read(recordingNotifierProvider.future);
|
|
|
|
|
-
|
|
|
|
|
- await Future.delayed(const Duration(milliseconds: 500));
|
|
|
|
|
-
|
|
|
|
|
- final audioMessages = fakeWebSocket.sentMessages
|
|
|
|
|
- .whereType<AudioMessage>();
|
|
|
|
|
- expect(audioMessages, isNotEmpty);
|
|
|
|
|
- expect(audioMessages.first.data, 'Zm9v');
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- test('stops sending audio chunks after pause', () async {
|
|
|
|
|
- fakeAudio.chunkData = 'YmFy';
|
|
|
|
|
- await container.read(recordingNotifierProvider.future);
|
|
|
|
|
-
|
|
|
|
|
- await Future.delayed(const Duration(milliseconds: 350));
|
|
|
|
|
- container.read(recordingNotifierProvider.notifier).pauseRecording();
|
|
|
|
|
- final sentBeforePause = fakeWebSocket.sentMessages
|
|
|
|
|
- .whereType<AudioMessage>()
|
|
|
|
|
- .length;
|
|
|
|
|
- expect(sentBeforePause, greaterThanOrEqualTo(1));
|
|
|
|
|
-
|
|
|
|
|
- await Future.delayed(const Duration(milliseconds: 400));
|
|
|
|
|
- final sentAfterPause = fakeWebSocket.sentMessages
|
|
|
|
|
- .whereType<AudioMessage>()
|
|
|
|
|
- .length;
|
|
|
|
|
- expect(sentAfterPause, sentBeforePause);
|
|
|
|
|
- });
|
|
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|