178     }

   178     }

   179 

   179 

   180     @Override

   180     @Override

   181     public void onError(WebSocket webSocket, Throwable error) {

   181     public void onError(WebSocket webSocket, Throwable error) {

   182         System.out.printf("onError(%s, %s)%n", webSocket, error);

   182         System.out.printf("onError(%s, %s)%n", webSocket, error);

   183         OnError inv = new OnError(webSocket, error == null ? null : error.getClass());

   184         OnError inv = new OnError(webSocket, error == null ? null : error.getClass());

   184         synchronized (invocations) {

   185         synchronized (invocations) {

   185             invocations.add(inv);

   186             invocations.add(inv);

   186         }

   187         }

   187         if (collectUntil.test(inv)) {

   188         if (collectUntil.test(inv)) {