net.minecraft.world.storage

Class StorageIoWorker

java.lang.Object

net.minecraft.world.storage.StorageIoWorker

All Implemented Interfaces:

AutoCloseable

public class StorageIoWorker
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	StorageIoWorker.Priority
(package private) static class	StorageIoWorker.Result

Field Summary

Fields

Modifier and Type	Field and Description
private AtomicBoolean	closed
private TaskExecutor<TaskQueue.PrioritizedTask>	field_24468
private static Logger	LOGGER
private Map<ChunkPos,StorageIoWorker.Result>	results
private RegionBasedStorage	storage

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StorageIoWorker(File file, boolean bool, String string)

Method Summary

Modifier and Type	Method and Description
void	close()
CompletableFuture<Void>	completeAll()
CompoundTag	getNbt(ChunkPos pos)
private void	method_27945()
private <T> CompletableFuture<T>	run(Supplier<com.mojang.datafixers.util.Either<T,Exception>> supplier)
CompletableFuture<Void>	setResult(ChunkPos pos, CompoundTag nbt)
private void	write(ChunkPos pos, StorageIoWorker.Result result)
private void	writeResult()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final Logger LOGGER

closed

private final AtomicBoolean closed

field_24468

private final TaskExecutor<TaskQueue.PrioritizedTask> field_24468

storage

private final RegionBasedStorage storage

results

private final Map<ChunkPos,StorageIoWorker.Result> results

Constructor Detail

StorageIoWorker

protected StorageIoWorker(File file,
                          boolean bool,
                          String string)

Method Detail

setResult

public CompletableFuture<Void> setResult(ChunkPos pos,
                                         CompoundTag nbt)

getNbt

@Nullable
public CompoundTag getNbt(ChunkPos pos)
                             throws IOException

Throws:

IOException

completeAll

public CompletableFuture<Void> completeAll()

run

private <T> CompletableFuture<T> run(Supplier<com.mojang.datafixers.util.Either<T,Exception>> supplier)

writeResult

private void writeResult()

method_27945

private void method_27945()

write

private void write(ChunkPos pos,
                   StorageIoWorker.Result result)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException