@Test @SuppressWarnings("CheckReturnValue") public void readDoesNotExist() throws FileNotFoundException { when(fileSystem.exists(resolvedPath)) .thenReturn(false); fileSystemPersister.read(simple).test().assertError(FileNotFoundException.class); }
@Nonnull @Override public Maybe<BufferedSource> read(@Nonnull Key key) { return fileReader.read(key); }
FileSystemRecordPersister implements Persister<BufferedSource, Key>, RecordProvider<Key> { @Nonnull @Override public Maybe<BufferedSource> read(@Nonnull Key key) { return fileReader.read(key); } }
FileSystemRecordPersister implements Persister<BufferedSource, Key>, RecordProvider<Key> { @Nonnull @Override public Maybe<BufferedSource> read(@Nonnull Key key) { return fileReader.read(key); } private  FileSystemRecordPersister(FileSystem fileSystem, PathResolver<Key> pathResolver,
                                      long expirationDuration,
                                      @Nonnull TimeUnit expirationUnit); }
FileSystemRecordPersister implements Persister<BufferedSource, Key>, RecordProvider<Key> { @Nonnull @Override public Maybe<BufferedSource> read(@Nonnull Key key) { return fileReader.read(key); } private  FileSystemRecordPersister(FileSystem fileSystem, PathResolver<Key> pathResolver,
                                      long expirationDuration,
                                      @Nonnull TimeUnit expirationUnit); @Nonnull static FileSystemRecordPersister<T> create(FileSystem fileSystem,
                                                          PathResolver<T> pathResolver,
                                                          long expirationDuration,
                                                          @Nonnull TimeUnit expirationUnit); @Nonnull @Override RecordState getRecordState(@Nonnull Key key); @Nonnull @Override Maybe<BufferedSource> read(@Nonnull Key key); @Nonnull @Override Single<Boolean> write(@Nonnull Key key, @Nonnull BufferedSource bufferedSource); }
FileSystemRecordPersister implements Persister<BufferedSource, Key>, RecordProvider<Key> { @Nonnull @Override public Maybe<BufferedSource> read(@Nonnull Key key) { return fileReader.read(key); } private  FileSystemRecordPersister(FileSystem fileSystem, PathResolver<Key> pathResolver,
                                      long expirationDuration,
                                      @Nonnull TimeUnit expirationUnit); @Nonnull static FileSystemRecordPersister<T> create(FileSystem fileSystem,
                                                          PathResolver<T> pathResolver,
                                                          long expirationDuration,
                                                          @Nonnull TimeUnit expirationUnit); @Nonnull @Override RecordState getRecordState(@Nonnull Key key); @Nonnull @Override Maybe<BufferedSource> read(@Nonnull Key key); @Nonnull @Override Single<Boolean> write(@Nonnull Key key, @Nonnull BufferedSource bufferedSource);  }