Package test.shell.sync

Examples of test.shell.sync.SyncProcess

333
334
335
336
337
338
339
340
341
342
343
    driver.assertCRLF().assertFlush().assertChar('%').assertChar(' ').assertFlush().assertEmpty();
  }

  public void testHandleKeyInProcess() {
    final ArrayBlockingQueue<Integer> keys = new ArrayBlockingQueue<Integer>(1);
    shell.addProcess(new SyncProcess() {
      @Override
      protected KeyHandler createKeyHandler() {
        return new KeyHandler() {
          @Override
          public void handle(KeyType type, int[] sequence) {
View Full Code Here
356
357
358
359
360
361
362
363
364
365
366
    assertEquals((int)'b', (int)keys.poll());
    assertFalse(console.getKeyBuffer().iterator().hasNext());
  }

  public void testHandleKeyExceptionInProcess() {
    shell.addProcess(new SyncProcess() {
      @Override
      protected KeyHandler createKeyHandler() {
        return new KeyHandler() {
          @Override
          public void handle(KeyType type, int[] sequence) {
View Full Code Here
462
463
464
465
466
467
468
469
470
471
472
    driver.assertChar('a').assertFlush();
    driver.assertChar('\\').assertFlush();
    driver.assertCRLF().assertChars("> ").assertFlush();
    driver.assertChar('b').assertFlush().assertEmpty();
    final ArrayList<String> requests = new ArrayList<String>();
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        requests.add(request);
      }
    });
View Full Code Here
492
493
494
495
496
497
498
499
500
501
502
    driver.assertCRLF().assertChars("> ").assertFlush();
    driver.assertChar('c').assertFlush();
    driver.assertChar('"').assertFlush();
    driver.assertChar('d').assertFlush().assertEmpty();
    final ArrayList<String> requests = new ArrayList<String>();
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        requests.add(request);
      }
    });
View Full Code Here
533
534
535
536
537
538
539
540
541
542
543
    driver.assertChars("d ").assertFlush().assertEmpty();
  }

  public void testInterruptMultiline() throws Exception {
    final ArrayBlockingQueue<String> keys = new ArrayBlockingQueue<String>(1);
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        keys.add(request);
      }
    });
View Full Code Here
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
    console.init();
    console.on(KeyStrokes.UP);
    driver.assertEmpty();
    console.on(KeyStrokes.DOWN);
    driver.assertEmpty();
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        context.end(ShellResponse.ok());
      }
    });
    console.on(KeyStrokes.a);
    console.on(KeyStrokes.ENTER);
    driver.assertChar('a').assertFlush().assertCRLF().assertFlush().assertCRLF().assertFlush().assertEmpty();
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        context.end(ShellResponse.ok());
      }
    });
    console.on(KeyStrokes.b);
    console.on(KeyStrokes.ENTER);
    driver.assertChar('b').assertFlush().assertCRLF().assertFlush().assertCRLF().assertFlush().assertEmpty();
    console.on(KeyStrokes.c);
    driver.assertChar('c').assertFlush().assertEmpty();
    console.on(KeyStrokes.UP);
    driver.assertDel().assertChar('b').assertFlush().assertEmpty();
    console.on(KeyStrokes.UNDERSCORE);
    driver.assertChar('_').assertFlush().assertEmpty();
    console.on(KeyStrokes.UP);
    driver.assertDel().assertDel().assertChar('a').assertFlush().assertEmpty();
    console.on(KeyStrokes.UP);
    driver.assertEmpty();
    console.on(KeyStrokes.DOWN);
    driver.assertDel().assertChar('b').assertChar('_').assertFlush().assertEmpty();
    console.on(KeyStrokes.DOWN);
    driver.assertDel().assertDel().assertChar('c').assertFlush().assertEmpty();
    console.on(KeyStrokes.DOWN);
    driver.assertEmpty();
    console.on(KeyStrokes.UP);
    driver.assertDel().assertChar('b').assertChar('_').assertFlush().assertEmpty();
    console.on(KeyStrokes.ONE);
    driver.assertChar('1').assertFlush().assertEmpty();
    final ArrayList<String> requests = new ArrayList<String>();
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        requests.add(request);
        context.end(ShellResponse.ok());
      }
View Full Code Here
617
618
619
620
621
622
623
624
625
626
627
    driver.assertDel().assertDel().assertChar('a').assertFlush().assertEmpty();
  }

  public void testReadLine1() throws Exception {
    final ArrayBlockingQueue<ShellProcessContext> contexts = new ArrayBlockingQueue<ShellProcessContext>(1);
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        contexts.add(context);
      }
    });
View Full Code Here
660
661
662
663
664
665
666
667
668
669
670
   * Same than {@link #testReadLine1()} but we provide input before the thread read lines effectively
   * which leads to a simpler test since we need only one thread
   */
  public void testReadLine2() throws Exception {
    final ArrayBlockingQueue<ShellProcessContext> contexts = new ArrayBlockingQueue<ShellProcessContext>(1);
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        contexts.add(context);
      }
    });
View Full Code Here
688
689
690
691
692
693
694
695
696
697
698
   * - we cannot call readline twice at the same time and
   * - if the reading thread is interrupted then it throws InterruptedIOException
   */
  public void testReadLine3() throws Exception {
    final ArrayBlockingQueue<ShellProcessContext> contexts = new ArrayBlockingQueue<ShellProcessContext>(1);
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        contexts.add(context);
      }
    });
View Full Code Here
736
737
738
739
740
741
742
743
744
745
746
  /**
   * Make sure that a reading thread is interrupted when the process ends
   */
  public void testReadLine4() throws Exception {
    final ArrayBlockingQueue<ShellProcessContext> contexts = new ArrayBlockingQueue<ShellProcessContext>(1);
    shell.addProcess(new SyncProcess() {
      @Override
      public void run(String request, ShellProcessContext context) throws Exception {
        contexts.add(context);
      }
    });
View Full Code Here
TOP

Related Classes of test.shell.sync.SyncProcess

  • org.crsh.console.ConsoleTestCase
  • org.crsh.console.operations.AcceptLineTestCase
  • org.crsh.console.operations.HistoryTestCase
  • org.crsh.console.operations.InsertCommentTestCase
  • org.crsh.console.operations.InterruptTestCase
  • org.crsh.console.operations.ViEofMaybeTestCase
  • org.crsh.console.operations.ViMoveAcceptLineTestCase
  • org.crsh.ssh.SSHTestCase
  • org.crsh.telnet.term.AbstractProcessorTestCase
  • org.crsh.telnet.term.AsyncProcessorTestCase
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.