Home
last modified time | relevance | path

Searched full:closer (Results 1 – 25 of 843) sorted by relevance

12345678910>>...34

/external/guava/guava-tests/test/com/google/common/io/
DCloserTest.java27 import com.google.common.io.Closer.LoggingSuppressor;
38 * Tests for {@link Closer}.
53 assertThat(Closer.create().suppressor).isInstanceOf(Closer.SuppressingSuppressor.class); in testCreate()
57 Closer closer = new Closer(suppressor); in testNoExceptionsThrown() local
59 TestCloseable c1 = closer.register(TestCloseable.normal()); in testNoExceptionsThrown()
60 TestCloseable c2 = closer.register(TestCloseable.normal()); in testNoExceptionsThrown()
61 TestCloseable c3 = closer.register(TestCloseable.normal()); in testNoExceptionsThrown()
67 closer.close(); in testNoExceptionsThrown()
77 Closer closer = new Closer(suppressor); in testExceptionThrown_fromTryBlock() local
79 TestCloseable c1 = closer.register(TestCloseable.normal()); in testExceptionThrown_fromTryBlock()
[all …]
/external/guava/android/guava-tests/test/com/google/common/io/
DCloserTest.java27 import com.google.common.io.Closer.LoggingSuppressor;
38 * Tests for {@link Closer}.
53 assertThat(Closer.create().suppressor).isInstanceOf(Closer.SuppressingSuppressor.class); in testCreate()
57 Closer closer = new Closer(suppressor); in testNoExceptionsThrown() local
59 TestCloseable c1 = closer.register(TestCloseable.normal()); in testNoExceptionsThrown()
60 TestCloseable c2 = closer.register(TestCloseable.normal()); in testNoExceptionsThrown()
61 TestCloseable c3 = closer.register(TestCloseable.normal()); in testNoExceptionsThrown()
67 closer.close(); in testNoExceptionsThrown()
77 Closer closer = new Closer(suppressor); in testExceptionThrown_fromTryBlock() local
79 TestCloseable c1 = closer.register(TestCloseable.normal()); in testExceptionThrown_fromTryBlock()
[all …]
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
DFilterChainSelectorManager.java39 private TreeSet<Closer> closers = new TreeSet<Closer>(new CloserComparator());
41 public FilterChainSelector register(Closer closer) { in register() argument
43 Preconditions.checkState(closers.add(closer), "closer already registered"); in register()
48 public void deregister(Closer closer) { in deregister() argument
50 closers.remove(closer); in deregister()
62 TreeSet<Closer> oldClosers; in updateSelector()
65 closers = new TreeSet<Closer>(closers.comparator()); in updateSelector()
68 for (Closer closer : oldClosers) { in updateSelector()
69 closer.closer.run(); in updateSelector()
80 public static final class Closer { class in FilterChainSelectorManager
[all …]
DFilterChainMatchingProtocolNegotiators.java111 FilterChainSelectorManager.Closer closer = new FilterChainSelectorManager.Closer( in userEventTriggered() local
113 FilterChainSelector selector = filterChainSelectorManager.register(closer); in userEventTriggered()
115 new FilterChainSelectorManagerDeregister(filterChainSelectorManager, closer)); in userEventTriggered()
419 private final FilterChainSelectorManager.Closer closer; field in FilterChainMatchingProtocolNegotiators.FilterChainSelectorManagerDeregister
423 FilterChainSelectorManager.Closer closer) { in FilterChainSelectorManagerDeregister() argument
426 this.closer = checkNotNull(closer, "closer"); in FilterChainSelectorManagerDeregister()
430 filterChainSelectorManager.deregister(closer); in operationComplete()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractClosingFutureTest.java123 public String apply(DeferredCloser closer, TestCloseable v) throws Exception { in testFrom()
148 public String apply(DeferredCloser closer, TestCloseable v) throws Exception { in testEventuallyClosing()
211 public TestCloseable call(DeferredCloser closer) throws Exception { in testSubmit()
212 closer.eventuallyClose(closeable1, closingExecutor); in testSubmit()
213 closer.eventuallyClose(closeable2, closingExecutor); in testSubmit()
221 public String apply(DeferredCloser closer, TestCloseable v) throws Exception { in testSubmit()
240 public TestCloseable call(DeferredCloser closer) throws Exception { in testSubmit_cancelledPipeline()
242 closer.eventuallyClose(closeable1, closingExecutor); in testSubmit_cancelledPipeline()
243 closer.eventuallyClose(closeable2, closingExecutor); in testSubmit_cancelledPipeline()
260 public Object call(DeferredCloser closer) throws Exception { in testSubmit_throws()
[all …]
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractClosingFutureTest.java123 public String apply(DeferredCloser closer, TestCloseable v) throws Exception { in testFrom()
148 public String apply(DeferredCloser closer, TestCloseable v) throws Exception { in testEventuallyClosing()
211 public TestCloseable call(DeferredCloser closer) throws Exception { in testSubmit()
212 closer.eventuallyClose(closeable1, closingExecutor); in testSubmit()
213 closer.eventuallyClose(closeable2, closingExecutor); in testSubmit()
221 public String apply(DeferredCloser closer, TestCloseable v) throws Exception { in testSubmit()
240 public TestCloseable call(DeferredCloser closer) throws Exception { in testSubmit_cancelledPipeline()
242 closer.eventuallyClose(closeable1, closingExecutor); in testSubmit_cancelledPipeline()
243 closer.eventuallyClose(closeable2, closingExecutor); in testSubmit_cancelledPipeline()
260 public Object call(DeferredCloser closer) throws Exception { in testSubmit_throws()
[all …]
/external/guava/android/guava/src/com/google/common/io/
DCharSource.java170 Closer closer = Closer.create(); in length() local
172 Reader reader = closer.register(openStream()); in length()
175 throw closer.rethrow(e); in length()
177 closer.close(); in length()
202 Closer closer = Closer.create(); in copyTo() local
204 Reader reader = closer.register(openStream()); in copyTo()
207 throw closer.rethrow(e); in copyTo()
209 closer.close(); in copyTo()
224 Closer closer = Closer.create(); in copyTo() local
226 Reader reader = closer.register(openStream()); in copyTo()
[all …]
DByteSource.java157 Closer closer = Closer.create(); in isEmpty() local
159 InputStream in = closer.register(openStream()); in isEmpty()
162 throw closer.rethrow(e); in isEmpty()
164 closer.close(); in isEmpty()
211 Closer closer = Closer.create(); in size() local
213 InputStream in = closer.register(openStream()); in size()
218 closer.close(); in size()
221 closer = Closer.create(); in size()
223 InputStream in = closer.register(openStream()); in size()
226 throw closer.rethrow(e); in size()
[all …]
DCharSink.java95 Closer closer = Closer.create(); in write() local
97 Writer out = closer.register(openStream()); in write()
101 throw closer.rethrow(e); in write()
103 closer.close(); in write()
129 Closer closer = Closer.create(); in writeLines() local
131 Writer out = closer.register(openBufferedStream()); in writeLines()
137 throw closer.rethrow(e); in writeLines()
139 closer.close(); in writeLines()
155 Closer closer = Closer.create(); in writeFrom() local
157 Writer out = closer.register(openStream()); in writeFrom()
[all …]
DCloser.java45 * Closer closer = Closer.create();
47 * InputStream in = closer.register(openInputStream());
48 * OutputStream out = closer.register(openOutputStream());
52 * // provided here, e.g. throw closer.rethrow(e, CheckedException.class);
53 * throw closer.rethrow(e);
55 * closer.close();
89 // Coffee's for {@link Closer closers} only.
93 public final class Closer implements Closeable { class
103 /** Creates a new {@link Closer}. */
104 public static Closer create() { in create()
[all …]
DByteSink.java102 Closer closer = Closer.create(); in write() local
104 OutputStream out = closer.register(openStream()); in write()
108 throw closer.rethrow(e); in write()
110 closer.close(); in write()
125 Closer closer = Closer.create(); in writeFrom() local
127 OutputStream out = closer.register(openStream()); in writeFrom()
132 throw closer.rethrow(e); in writeFrom()
134 closer.close(); in writeFrom()
/external/guava/guava/src/com/google/common/io/
DCharSource.java216 Closer closer = Closer.create();
218 Reader reader = closer.register(openStream());
221 throw closer.rethrow(e);
223 closer.close();
248 Closer closer = Closer.create();
250 Reader reader = closer.register(openStream());
253 throw closer.rethrow(e);
255 closer.close();
270 Closer closer = Closer.create();
272 Reader reader = closer.register(openStream());
[all …]
DByteSource.java157 Closer closer = Closer.create(); in isEmpty() local
159 InputStream in = closer.register(openStream()); in isEmpty()
162 throw closer.rethrow(e); in isEmpty()
164 closer.close(); in isEmpty()
211 Closer closer = Closer.create(); in size() local
213 InputStream in = closer.register(openStream()); in size()
218 closer.close(); in size()
221 closer = Closer.create(); in size()
223 InputStream in = closer.register(openStream()); in size()
226 throw closer.rethrow(e); in size()
[all …]
DCloser.java45 * Closer closer = Closer.create();
47 * InputStream in = closer.register(openInputStream());
48 * OutputStream out = closer.register(openOutputStream());
52 * // provided here, e.g. throw closer.rethrow(e, CheckedException.class);
53 * throw closer.rethrow(e);
55 * closer.close();
89 // Coffee's for {@link Closer closers} only.
93 public final class Closer implements Closeable { class
103 /** Creates a new {@link Closer}. */
104 public static Closer create() { in create()
[all …]
DByteSink.java102 Closer closer = Closer.create(); in write() local
104 OutputStream out = closer.register(openStream()); in write()
108 throw closer.rethrow(e); in write()
110 closer.close(); in write()
125 Closer closer = Closer.create(); in writeFrom() local
127 OutputStream out = closer.register(openStream()); in writeFrom()
132 throw closer.rethrow(e); in writeFrom()
134 closer.close(); in writeFrom()
DCharSink.java97 Closer closer = Closer.create(); in write() local
99 Writer out = closer.register(openStream()); in write()
103 throw closer.rethrow(e); in write()
105 closer.close(); in write()
178 Closer closer = Closer.create(); in writeFrom() local
180 Writer out = closer.register(openStream()); in writeFrom()
185 throw closer.rethrow(e); in writeFrom()
187 closer.close(); in writeFrom()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DFilterChainSelectorManagerTest.java26 import io.grpc.xds.FilterChainSelectorManager.Closer;
52 assertThat(manager.register(new Closer(runnable1))).isNull(); in updateSelector_changesSelector()
58 assertThat(manager.register(new Closer(runnable2))).isSameInstanceAs(selector1); in updateSelector_changesSelector()
64 assertThat(manager.register(new Closer(runnable1))).isNull(); in updateSelector_callsCloserOnce()
74 Closer closer1 = new Closer(runnable1); in deregister_removesCloser()
88 Closer closer1 = new Closer(runnable1); in deregister_removesCorrectCloser()
89 Closer closer2 = new Closer(runnable2); in deregister_removesCorrectCloser()
/external/nullaway/guava-recent-unit-tests/src/test/java/com/uber/nullaway/guava/
DNullAwayGuavaParametricNullnessTests.java100 "import com.google.common.io.Closer;", in testCloserParametricNullness()
105 " public static FileInputStream test1(Closer closer, FileInputStream fis1) {", in testCloserParametricNullness()
107 " return closer.register(fis1);", in testCloserParametricNullness()
110 … " public static FileInputStream test2(Closer closer, @Nullable FileInputStream fis2) {", in testCloserParametricNullness()
112 " return closer.register(fis2);", in testCloserParametricNullness()
114 … " public static FileInputStream test3(Closer closer, @Nullable FileInputStream fis3) {", in testCloserParametricNullness()
116 " return closer.register(fis3);", in testCloserParametricNullness()
/external/desugar/test/java/com/google/devtools/build/android/desugar/
DDefaultMethodClassFixerTest.java21 import com.google.common.io.Closer;
57 private Closer closer; field in DefaultMethodClassFixerTest
61 closer = Closer.create(); in setup()
65 toIndexedInputs(closer, System.getProperty("DefaultMethodClassFixerTest.input")); in setup()
67 toIndexedInputs(closer, System.getProperty("DefaultMethodClassFixerTest.classpath")); in setup()
69 toIndexedInputs(closer, System.getProperty("DefaultMethodClassFixerTest.bootclasspath")); in setup()
81 closer.close(); in teardown()
84 private static IndexedInputs toIndexedInputs(Closer closer, String stringPathList) in toIndexedInputs() argument
87 return new IndexedInputs(Desugar.toRegisteredInputFileProvider(closer, pathList)); in toIndexedInputs()
/external/guava/guava/src/com/google/common/util/concurrent/
DClosingFuture.java146 * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
148 * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
149 * .transform((closer, result) -> result.get("userName"), directExecutor())
165 * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
167 * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
168 * .transform((closer, result) -> result.get("userName"), directExecutor())
257 * closer.eventuallyClose()} will be closed when the {@link ClosingFuture} pipeline is done (but
261 V call(DeferredCloser closer) throws Exception; in call() argument
276 * closer.eventuallyClose()} will be closed when the {@link ClosingFuture} pipeline is done (but
279 ClosingFuture<V> call(DeferredCloser closer) throws Exception; in call() argument
[all …]
/external/guava/android/guava/src/com/google/common/util/concurrent/
DClosingFuture.java146 * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
148 * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
149 * .transform((closer, result) -> result.get("userName"), directExecutor())
165 * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
167 * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
168 * .transform((closer, result) -> result.get("userName"), directExecutor())
257 * closer.eventuallyClose()} will be closed when the {@link ClosingFuture} pipeline is done (but
261 V call(DeferredCloser closer) throws Exception; in call() argument
275 * closer.eventuallyClose()} will be closed when the {@link ClosingFuture} pipeline is done (but
278 ClosingFuture<V> call(DeferredCloser closer) throws Exception; in call() argument
[all …]
/external/python/cpython3/Lib/idlelib/
Dparenmatch.py19 opener -- highlight the matching left paren (closer);
20 parens -- highlight the left and right parens (opener and closer);
21 expression -- highlight the entire expression from opener to closer.
30 - Highlight when cursor is moved to the right of a closer.
84 "Handle user input of closer."
85 # If user bound non-closer to <<paren-closed>>, quit.
86 closer = self.text.get("insert-1c")
87 if closer not in _openers:
92 indices = hp.get_surrounding_brackets(_openers[closer], True)
/external/caliper/caliper/src/main/java/com/google/caliper/config/
DLoggingConfigLoader.java26 import com.google.common.io.Closer;
62 Closer closer = Closer.create(); in loadLoggingConfig() local
65 fis = closer.register(new FileInputStream(loggingPropertiesFile)); in loadLoggingConfig()
73 closer.close(); in loadLoggingConfig()
/external/desugar/java/com/google/devtools/build/android/desugar/scan/
DKeepScanner.java25 import com.google.common.io.Closer;
123 try (Closer closer = Closer.create()) { in main() argument
126 new IndexedInputs(toRegisteredInputFileProvider(closer, options.classpath)); in main()
128 new IndexedInputs(toRegisteredInputFileProvider(closer, options.bootclasspath)); in main()
290 * closer.
294 Closer closer, List<Path> paths) throws IOException { in toRegisteredInputFileProvider() argument
297 builder.add(closer.register(InputFileProvider.open(path))); in toRegisteredInputFileProvider()
/external/caliper/caliper/src/main/java/com/google/caliper/util/
DUtil.java24 import com.google.common.io.Closer;
71 Closer closer = Closer.create(); in loadProperties() local
72 InputStream in = closer.register(is.openStream()); in loadProperties()
76 closer.close(); in loadProperties()

12345678910>>...34