Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 608 for Closed (0.04 seconds)

  1. android/guava-tests/test/com/google/common/io/TestByteSource.java

      private final class In extends TestInputStream {
    
        In() throws IOException {
          super(new ByteArrayInputStream(bytes), options);
        }
    
        @Override
        public void close() throws IOException {
          inputStreamClosed = true;
          super.close();
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 2K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/io/TestByteSource.java

      private final class In extends TestInputStream {
    
        In() throws IOException {
          super(new ByteArrayInputStream(bytes), options);
        }
    
        @Override
        public void close() throws IOException {
          inputStreamClosed = true;
          super.close();
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 2K bytes
    - Click Count (0)
  3. fastapi/datastructures.py

            """
            return await super().seek(offset)
    
        async def close(self) -> None:
            """
            Close the file.
    
            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().close()
    
        @classmethod
        def _validate(cls, __input_value: Any, _: Any) -> "UploadFile":
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  4. internal/http/listener_test.go

    		for _, serverAddr := range listener.Addrs() {
    			conn, err := net.Dial("tcp", serverAddr.String())
    			if err != nil {
    				t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err)
    			}
    			conn.Close()
    		}
    
    		listener.Close()
    	}
    }
    
    func TestHTTPListenerAddr(t *testing.T) {
    	if runtime.GOOS == "windows" {
    		t.Skip()
    	}
    
    	nonLoopBackIP := getNonLoopBackIP(t)
    	var casePorts []string
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  5. internal/store/batch_test.go

    		Limit:         limit,
    		Store:         store,
    		CommitTimeout: 5 * time.Minute,
    		Log: func(ctx context.Context, err error, id string, errKind ...any) {
    			t.Log(err)
    		},
    	})
    	defer batch.Close()
    
    	for i := 0; i < int(limit); i++ {
    		if err := batch.Add(testItem); err != nil {
    			t.Fatalf("failed to add %v; %v", i, err)
    		}
    	}
    
    	batchLen := batch.Len()
    	if batchLen != int(limit) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/io/MultiReaderTest.java

                  throw new IllegalStateException("More than one source open");
                }
                return new FilterReader(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
                  }
                };
              }
            };
        Reader joinedReader = CharSource.concat(reader, reader, reader).openStream();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  7. tests/test_validation_error_context.py

        await websocket.send_text(f"Item: {item_id}")  # pragma: no cover
        await websocket.close()  # pragma: no cover
    
    
    @sub_app.websocket("/ws/{item_id}")
    async def subapp_websocket_endpoint(websocket: WebSocket, item_id: int):
        await websocket.accept()  # pragma: no cover
        await websocket.send_text(f"Item: {item_id}")  # pragma: no cover
        await websocket.close()  # pragma: no cover
    
    
    client = TestClient(app)
    
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 06 12:21:57 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  8. internal/ioutil/wait_pipe.go

    	done func()
    }
    
    // CloseWithError close with supplied error the writer end.
    func (w *PipeWriter) CloseWithError(err error) error {
    	err = w.PipeWriter.CloseWithError(err)
    	w.once.Do(func() {
    		w.done()
    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    // CloseWithError close with supplied error the reader end
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 27 14:55:36 GMT 2023
    - 1.7K bytes
    - Click Count (0)
  9. build-logic/documentation/src/test/resources/org/gradle/test/GroovyClassWithImports.groovy

    package org.gradle.test
    
    import org.gradle.test.sub.*;
    
    class GroovyClassWithImports extends SubGroovyClass implements SubJavaInterface, GroovyInterface {
        void close() {
        }
    }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 228 bytes
    - Click Count (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java

                    result.eventSpyDispatcher = shellContext.eventSpyDispatcher;
                };
            }
    
            @Override
            public void close() throws Exception {
                shellMavenInvoker.close();
                shellEncryptInvoker.close();
                shellUpgradeInvoker.close();
            }
    
            @Override
            public List<String> commandInfo(String command) {
                return List.of();
            }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Jun 07 06:22:47 GMT 2025
    - 12.3K bytes
    - Click Count (0)
Back to Top