本文整理了Java中io.advantageous.boon.core.IO.puts()
方法的一些代码示例,展示了IO.puts()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IO.puts()
方法的具体详情如下:
包路径:io.advantageous.boon.core.IO
类名称: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!