METHOD_0 ( ) { org . mockito . Mockito . when ( client . METHOD_1 ( IDENT_0 . IDENT_1 , IDENT_2 . IDENT_3 ) ) . thenReturn ( IDENT_4 . IDENT_5 . METHOD_2 ( ) ) ; org . mockito . Mockito . when ( client . METHOD_3 ( org . mockito . Mockito . < java . lang . IDENT_6 [ ] > METHOD_4 ( ) ) ) . thenReturn ( IDENT_4 . IDENT_5 . METHOD_2 ( ) ) ; com . couchbase . client . IDENT_7 . state . IDENT_8 IDENT_9 = org . mockito . Mockito . mock ( com . couchbase . client . IDENT_7 . state . IDENT_8 . class ) ; org . mockito . Mockito . when ( IDENT_9 . METHOD_5 ( ) ) . thenReturn ( false , false , true ) ; org . mockito . Mockito . when ( client . METHOD_6 ( ) ) . thenReturn ( METHOD_6 ) ; java . util . concurrent . IDENT_10 < com . couchbase . client . IDENT_11 . io . netty . buffer . IDENT_12 > IDENT_13 = new java . util . concurrent . METHOD_7 ( 3 ) ; IDENT_14 . METHOD_3 ( IDENT_13 ) ; "<AssertPlaceHolder>" ; java . lang . Thread . sleep ( INT_0 ) ; org . mockito . Mockito . verify ( client , org . mockito . Mockito . times ( 3 ) ) . METHOD_6 ( ) ; } METHOD_8 ( ) { return streaming ; }
org . junit . Assert . assertTrue ( IDENT_14 . METHOD_8 ( ) )