Skip to content

Commit c1e0a00

Browse files
committed
Restore tests for SPSC as close as we can
1 parent e21c402 commit c1e0a00

File tree

2 files changed

+14
-14
lines changed

2 files changed

+14
-14
lines changed

src/spsc/mod.rs

+13-13
Original file line numberDiff line numberDiff line change
@@ -588,7 +588,7 @@ mod tests {
588588

589589
#[test]
590590
fn full() {
591-
let mut rb: Queue<i32, u8, 4> = Queue::u8();
591+
let mut rb: Queue<i32, _, 4> = Queue::new();
592592

593593
rb.enqueue(0).unwrap();
594594
rb.enqueue(1).unwrap();
@@ -600,7 +600,7 @@ mod tests {
600600

601601
#[test]
602602
fn iter() {
603-
let mut rb: Queue<i32, u16, 4> = Queue::u16();
603+
let mut rb: Queue<i32, _, 4> = Queue::new();
604604

605605
rb.enqueue(0).unwrap();
606606
rb.enqueue(1).unwrap();
@@ -616,7 +616,7 @@ mod tests {
616616

617617
#[test]
618618
fn iter_double_ended() {
619-
let mut rb: Queue<i32, u8, 4> = Queue::u8();
619+
let mut rb: Queue<i32, _, 4> = Queue::new();
620620

621621
rb.enqueue(0).unwrap();
622622
rb.enqueue(1).unwrap();
@@ -647,7 +647,7 @@ mod tests {
647647

648648
#[test]
649649
fn iter_mut() {
650-
let mut rb: Queue<i32, u8, 4> = Queue::u8();
650+
let mut rb: Queue<i32, _, 4> = Queue::new();
651651

652652
rb.enqueue(0).unwrap();
653653
rb.enqueue(1).unwrap();
@@ -663,7 +663,7 @@ mod tests {
663663

664664
#[test]
665665
fn iter_mut_double_ended() {
666-
let mut rb: Queue<i32, u8, 4> = Queue::u8();
666+
let mut rb: Queue<i32, _, 4> = Queue::new();
667667

668668
rb.enqueue(0).unwrap();
669669
rb.enqueue(1).unwrap();
@@ -680,7 +680,7 @@ mod tests {
680680

681681
#[test]
682682
fn sanity() {
683-
let mut rb: Queue<i32, u8, 4> = Queue::u8();
683+
let mut rb: Queue<i32, _, 4> = Queue::new();
684684
assert_eq!(rb.dequeue(), None);
685685
rb.enqueue(0).unwrap();
686686
assert_eq!(rb.dequeue(), Some(0));
@@ -701,7 +701,7 @@ mod tests {
701701

702702
#[test]
703703
fn wrap_around() {
704-
let mut rb: Queue<i32, u8, 3> = Queue::u8();
704+
let mut rb: Queue<i32, _, 3> = Queue::new();
705705

706706
rb.enqueue(0).unwrap();
707707
rb.enqueue(1).unwrap();
@@ -717,7 +717,7 @@ mod tests {
717717

718718
#[test]
719719
fn ready_flag() {
720-
let mut rb: Queue<i32, u8, 2> = Queue::u8();
720+
let mut rb: Queue<i32, _, 2> = Queue::new();
721721
let (mut p, mut c) = rb.split();
722722
assert_eq!(c.ready(), false);
723723
assert_eq!(p.ready(), true);
@@ -745,7 +745,7 @@ mod tests {
745745

746746
#[test]
747747
fn clone() {
748-
let mut rb1: Queue<i32, u8, 4> = Queue::u8();
748+
let mut rb1: Queue<i32, _, 4> = Queue::new();
749749
rb1.enqueue(0).unwrap();
750750
rb1.enqueue(0).unwrap();
751751
rb1.dequeue().unwrap();
@@ -760,12 +760,12 @@ mod tests {
760760
fn eq() {
761761
// generate two queues with same content
762762
// but different buffer alignment
763-
let mut rb1: Queue<i32, u8, 4> = Queue::u8();
763+
let mut rb1: Queue<i32, _, 4> = Queue::new();
764764
rb1.enqueue(0).unwrap();
765765
rb1.enqueue(0).unwrap();
766766
rb1.dequeue().unwrap();
767767
rb1.enqueue(0).unwrap();
768-
let mut rb2: Queue<i32, u8, 4> = Queue::u8();
768+
let mut rb2: Queue<i32, _, 4> = Queue::new();
769769
rb2.enqueue(0).unwrap();
770770
rb2.enqueue(0).unwrap();
771771
assert!(rb1 == rb2);
@@ -786,15 +786,15 @@ mod tests {
786786
// generate two queues with same content
787787
// but different buffer alignment
788788
let rb1 = {
789-
let mut rb1: Queue<i32, u8, 4> = Queue::u8();
789+
let mut rb1: Queue<i32, _, 4> = Queue::new();
790790
rb1.enqueue(0).unwrap();
791791
rb1.enqueue(0).unwrap();
792792
rb1.dequeue().unwrap();
793793
rb1.enqueue(0).unwrap();
794794
rb1
795795
};
796796
let rb2 = {
797-
let mut rb2: Queue<i32, u8, 4> = Queue::u8();
797+
let mut rb2: Queue<i32, _, 4> = Queue::new();
798798
rb2.enqueue(0).unwrap();
799799
rb2.enqueue(0).unwrap();
800800
rb2

src/spsc/split.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ mod tests {
248248

249249
#[test]
250250
fn sanity() {
251-
let mut rb: Queue<i32, u8, 2> = Queue::u8();
251+
let mut rb: Queue<i32, _, 2> = Queue::new();
252252

253253
let (mut p, mut c) = rb.split();
254254

0 commit comments

Comments
 (0)