@@ -50,6 +50,7 @@ public void testNotification() throws IOException, RestException, InterruptedExc
5050 ArgumentCaptor <String > argument = ArgumentCaptor .forClass (String .class );
5151 verify (consumer , atLeastOnce ()).accept (argument .capture ());
5252 assertTrue (argument .getValue ().contains ("uuid" ));
53+ subscription .revoke ();
5354 }
5455
5556 @ Test
@@ -68,6 +69,7 @@ public void testRefresh() throws IOException, RestException, InterruptedExceptio
6869 ArgumentCaptor <String > argument = ArgumentCaptor .forClass (String .class );
6970 verify (consumer , atLeastOnce ()).accept (argument .capture ());
7071 assertTrue (argument .getValue ().contains ("uuid" ));
72+ subscription .revoke ();
7173 }
7274
7375 @ Test
@@ -101,6 +103,7 @@ public void testStatusCallback() throws IOException, RestException, InterruptedE
101103 ArgumentCaptor <PNStatus > argument = ArgumentCaptor .forClass (PNStatus .class );
102104 verify (consumer2 , atLeastOnce ()).accept (argument .capture ());
103105 assertEquals (argument .getValue ().getStatusCode (), 200 );
106+ subscription .revoke ();
104107 }
105108
106109 @ Test
@@ -119,5 +122,6 @@ public void testAutoRefresh() throws IOException, RestException, InterruptedExce
119122 ArgumentCaptor <String > argument = ArgumentCaptor .forClass (String .class );
120123 verify (consumer , atLeastOnce ()).accept (argument .capture ());
121124 assertTrue (argument .getValue ().contains ("uuid" ));
125+ subscription .revoke ();
122126 }
123127}
0 commit comments