import io.objectos.core.IOProcess;
import io.objectos.core.Inputs;
import io.objectos.core.Objects;
public class FileReader {
public static void main(String[] args) {
Objects.io().execute(new IOProcess<Void>() {
@Override
protected Void process(Inputs inputs) throws Exception {
String content = inputs.file("path/to/file.txt").string();
System.out.println(content);
return null;
}
});
}
}
import io.objectos.core.IOProcess;
import io.objectos.core.Outputs;
import io.objectos.core.Objects;
public class SocketServer {
public static void main(String[] args) {
Objects.io().execute(new IOProcess<Void>() {
@Override
protected Void process(Outputs outputs) throws Exception {
outputs.serverSocket(8080).accept(socket -> {
String message = socket.read().string();
System.out.println("Received message: " + message);
socket.write("Hello from server!");
return null;
});
return null;
}
});
}
}
import io.objectos.core.IOProcess;
import io.objectos.core.Inputs;
import io.objectos.core.Objects;
public class ObjectSerialization {
public static void main(String[] args) {
MyObject obj = new MyObject();
obj.setName("John Doe");
obj.setAge(30);
Objects.io().execute(new IOProcess<Void>() {
@Override
protected Void process(Inputs inputs) throws Exception {
inputs.file("path/to/file.bin").object(obj);
return null;
}
});
}
}
