io.advantageous.boon.core.IO.puts()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(119)

本文整理了Java中io.advantageous.boon.core.IO.puts()方法的一些代码示例,展示了IO.puts()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IO.puts()方法的具体详情如下:
包路径:io.advantageous.boon.core.IO
类名称:IO
方法名:puts

IO.puts介绍

[英]Like print, but prints out a whole slew of objects on the same line.
[中]像打印一样,但在同一行上打印出一系列对象。

代码示例

代码示例来源:origin: advantageous/qbit

@Override
  public void servicesRemoved(String serviceName, int count) {
    puts("servicesRemoved", serviceName, count);
  }
};

代码示例来源:origin: advantageous/qbit

@Override
  public void accept(Long integer) {
    puts("Last ten second count for abc.count", integer);
  }
}, "abc.count");

代码示例来源:origin: advantageous/qbit

@Override
public void servicePoolChanged(String serviceName) {
  servicePoolChangedServiceNameFromListener.set(serviceName);
  puts(serviceName);
}

代码示例来源:origin: advantageous/qbit

@Override
  public void onError(Throwable error) {
    puts("We got", error.getMessage());
    ok = "Hi hi 5".equals(error.getMessage());
    wasError.set(true);
  }
};

代码示例来源:origin: advantageous/qbit

@Listen("NEW_RECORD_LIST")
  public void newRecords(List<Record> records) {
    puts("GOT NEW RECORDS", records);
    records.forEach(blockingQueue::add);
  }
}

代码示例来源:origin: advantageous/qbit

@RequestMapping("/todo/list/")
public List<Todo> list() {
  puts("List serviceCall was called", items);
  return new ArrayList<>(items);
}

代码示例来源:origin: advantageous/qbit

/**
 * This is a fire and forget style.
 * There is no return and the client cannot get any exception that this might throw.
 *
 * @param employee employee
 */
@RequestMapping(value = "/employee-add-async-no-return", method = RequestMethod.POST)
public void addEmployee(final Employee employee) {
  employeeList.add(employee);
  puts(employee);
}

代码示例来源:origin: advantageous/qbit

@RequestMapping(value = "/throw", method = RequestMethod.POST)
public void addEmployeeThrowException(final Callback<Boolean> callback,
                   final Employee employee) {
  puts(employee);
  throw new RuntimeException("OH NO");
}

代码示例来源:origin: advantageous/qbit

@Override
  public void event(String arg) {
    puts("GOT EVENT", arg);
    event.set(sputs("GOT EVENT", arg));
  }
}

代码示例来源:origin: advantageous/qbit

void doSomeWork2(Callback<Integer> value) {
  count++;
  totalCount++;
  puts(count, totalCount);
  value.accept(count);
}

代码示例来源:origin: advantageous/qbit

@Listen("NEW_RECORD")
public void newRecord(final Record record) {
  puts("GOT NEW RECORD", record);
  blockingQueue.add(record);
}

代码示例来源:origin: advantageous/qbit

@RequestMapping("/timeOut")
public String timeOut() {
  puts("TIMEOUT");
  Sys.sleep(30000);
  return "ok";
}

代码示例来源:origin: advantageous/qbit

private void loadServices(String serviceName) {
  for (int index = 0; index < 10; index++) {
    Sys.sleep(1000);
    final List<EndpointDefinition> endpointDefinitions = serviceDiscovery.loadServices(serviceName);
    puts(endpointDefinitions);
    if (endpointDefinitions.size() > 0) {
      break;
    }
  }
  Sys.sleep(100);
}

代码示例来源:origin: advantageous/qbit

@Test
public void testAddService() throws Exception {
  serviceBundle.addServiceObject("/adder", adderService);
  final List<String> endPoints = serviceBundle.endPoints();
  puts(endPoints);
  endPoints.contains("/foo/adder");
}

代码示例来源:origin: advantageous/qbit

private void loadServices(String serviceName) {
  for (int index = 0; index < 10; index++) {
    Sys.sleep(1000);
    final List<EndpointDefinition> endpointDefinitions = serviceDiscovery.loadServices(serviceName);
    puts(endpointDefinitions);
    if (endpointDefinitions.size() > 0) {
      break;
    }
  }
  Sys.sleep(100);
}

代码示例来源:origin: advantageous/qbit

@Test
public void addEmployeeThrowException() {
  final HttpTextResponse httpResponse = httpServerSimulator.postBody("/es/throw",
      new Employee(1, "Rick"));
  assertEquals(500, httpResponse.code());
  assertTrue(httpResponse.body().contains("\"message\":"));
  puts(httpResponse.body());
}

代码示例来源:origin: advantageous/qbit

@Test
public void test() throws Exception {
  final ServiceMeta myService = service("myService", "/myservice");
  puts(toJson(myService));
}

代码示例来源:origin: advantageous/qbit

@Test
public void testNoJSONParseWithBytes() {
  final HttpTextResponse httpResponse = httpServerSimulator.sendRequest(
      httpRequestBuilder.setUri("/es/body/bytes")
          .setMethodPost().setContentType("foo")
          .setBody("foo")
          .build()
  );
  puts(httpResponse);
  assertEquals(200, httpResponse.code());
  assertEquals("true", httpResponse.body());
}

代码示例来源:origin: advantageous/qbit

@Test
public void testCallBack() throws Exception {
  client.start();
  Sys.sleep(100);
  final ServiceMock mockService = client.createProxy(ServiceMock.class, "mockService");
  mockService.sum(integer -> puts("SUM", integer));
  ((ClientProxy) mockService).clientProxyFlush();
  Sys.sleep(100);
  ok = httpSendWebSocketCalled || die();
}

代码示例来源:origin: advantageous/qbit

public static void main(String... args) {
    final HttpClient httpClient = httpClientBuilder().setAutoFlush(true).setPort(9999).build();

    httpClient.startClient();

    final WebSocket webSocket = httpClient.createWebSocket("/hello");

    webSocket.setTextMessageConsumer(message ->
        puts("\n\n\n", message, "\n\n")
    );

    webSocket.openAndWait();

    webSocket.sendText("Hello");

    Sys.sleep(100000);
  }
}

相关文章