|
1 | | -package org.rocstreaming.roctoolkit; |
| 1 | +package org.rocstreaming.roctoolkit.integration; |
2 | 2 |
|
3 | 3 | import org.awaitility.Duration; |
4 | 4 | import org.junit.jupiter.api.Test; |
| 5 | +import org.rocstreaming.roctoolkit.*; |
5 | 6 |
|
6 | 7 | import java.io.IOException; |
7 | 8 | import java.util.concurrent.Executors; |
|
14 | 15 |
|
15 | 16 | public class RocSenderReceiverTest extends BaseTest { |
16 | 17 |
|
| 18 | + private static final int SAMPLE_RATE = 44100; |
| 19 | + |
| 20 | + private static final RocContextConfig CONTEXT_CONFIG = RocContextConfig.builder() |
| 21 | + .maxPacketSize(0) |
| 22 | + .maxFrameSize(0) |
| 23 | + .build(); |
| 24 | + |
| 25 | + private static final RocSenderConfig SENDER_CONFIG = RocSenderConfig.builder() |
| 26 | + .frameSampleRate(SAMPLE_RATE) |
| 27 | + .frameChannels(ChannelSet.STEREO) |
| 28 | + .frameEncoding(FrameEncoding.PCM_FLOAT) |
| 29 | + .clockSource(ClockSource.INTERNAL) |
| 30 | + .build(); |
| 31 | + |
| 32 | + private static final RocReceiverConfig RECEIVER_CONFIG = RocReceiverConfig.builder() |
| 33 | + .frameSampleRate(SAMPLE_RATE) |
| 34 | + .frameChannels(ChannelSet.STEREO) |
| 35 | + .frameEncoding(FrameEncoding.PCM_FLOAT) |
| 36 | + .clockSource(ClockSource.INTERNAL) |
| 37 | + .build(); |
| 38 | + |
17 | 39 | @Test |
18 | 40 | void testWriteRead() throws Exception { |
19 | 41 | try ( |
20 | | - RocContext context = new RocContext(); |
21 | | - RocSender sender = new RocSender(context, RocSenderTest.CONFIG); |
22 | | - RocReceiver receiver = new RocReceiver(context, RocReceiverTest.CONFIG) |
| 42 | + RocContext context = new RocContext(CONTEXT_CONFIG); |
| 43 | + RocSender sender = new RocSender(context, SENDER_CONFIG); |
| 44 | + RocReceiver receiver = new RocReceiver(context, RECEIVER_CONFIG) |
23 | 45 | ) { |
24 | 46 |
|
25 | 47 | Endpoint sourceEndpoint = new Endpoint("rtp+rs8m://127.0.0.1:10001"); |
|
0 commit comments