Improved typing
This commit is contained in:
@@ -3,6 +3,7 @@ package dev.selimaj.session;
|
||||
import com.fasterxml.jackson.databind.JsonNode;
|
||||
|
||||
import dev.selimaj.session.types.Message;
|
||||
import dev.selimaj.session.types.Method;
|
||||
|
||||
import java.net.URI;
|
||||
import java.net.http.HttpClient;
|
||||
@@ -46,11 +47,10 @@ public final class Session {
|
||||
listener.notify(ws, method, data);
|
||||
}
|
||||
|
||||
public <Req, Res> CompletableFuture<Res> request(
|
||||
String method,
|
||||
Req data,
|
||||
Class<Res> resType) throws Exception {
|
||||
return listener.request(ws, method, data, resType);
|
||||
<Req extends JsonNode, Res extends JsonNode, Err extends JsonNode> CompletableFuture<Res> request(
|
||||
Class<? extends Method<Req, Res, Err>> method, Req req) throws Exception {
|
||||
Method<Req, Res, Err> m = method.getDeclaredConstructor().newInstance();
|
||||
return listener.request(ws, m.getName(), req, m.getResClass());
|
||||
}
|
||||
|
||||
public void close() throws Exception {
|
||||
|
||||
@@ -2,6 +2,32 @@ package dev.selimaj.session.types;
|
||||
|
||||
import com.fasterxml.jackson.databind.JsonNode;
|
||||
|
||||
public interface Method<Req extends JsonNode, Res extends JsonNode, Err extends JsonNode> {
|
||||
String getName();
|
||||
}
|
||||
public class Method<Req extends JsonNode, Res extends JsonNode, Err extends JsonNode> {
|
||||
private final String name;
|
||||
private final Class<Req> reqClass;
|
||||
private final Class<Res> resClass;
|
||||
private final Class<Err> errClass;
|
||||
|
||||
protected Method(String name, Class<Req> reqClass, Class<Res> resClass, Class<Err> errClass) {
|
||||
this.name = name;
|
||||
this.reqClass = reqClass;
|
||||
this.resClass = resClass;
|
||||
this.errClass = errClass;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public Class<Req> getReqClass() {
|
||||
return reqClass;
|
||||
}
|
||||
|
||||
public Class<Res> getResClass() {
|
||||
return resClass;
|
||||
}
|
||||
|
||||
public Class<Err> getErrClass() {
|
||||
return errClass;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user