- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 824 for Gevent (0.04 sec)
-
guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus * may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. * * @author Cliff BiffleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 1.2K bytes - Viewed (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/DefaultArtifactDescriptorReader.java
RepositoryEvent.Builder event = new RepositoryEvent.Builder(session, EventType.ARTIFACT_DESCRIPTOR_MISSING); event.setTrace(trace); event.setArtifact(artifact); event.setException(exception); repositoryEventDispatcher.dispatch(event.build()); } private void invalidDescriptor(
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jan 10 08:42:00 UTC 2025 - 17.1K bytes - Viewed (0) -
.github/workflows/translate.yml
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 18:48:45 UTC 2025 - 3.6K bytes - Viewed (0) -
internal/event/targetlist_test.go
func (target ExampleTarget) ID() TargetID { return target.id } // Save - Sends event directly without persisting. func (target ExampleTarget) Save(eventData Event) error { return target.send(eventData) } // Store - Returns a nil store. func (target ExampleTarget) Store() TargetStore { return nil } func (target ExampleTarget) send(eventData Event) error { b := make([]byte, 1) if _, err := rand.Read(b); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 6K bytes - Viewed (0) -
docs/fr/docs/history-design-future.md
> Quelle est l'histoire de ce projet ? Il semble être sorti de nulle part et est devenu génial en quelques semaines [...]. Voici un petit bout de cette histoire. ## Alternatives
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 4.9K bytes - Viewed (0) -
docs/lambda/README.md
import requests app = Flask(__name__) @app.route('/', methods=['POST']) def get_webhook(): if request.method == 'POST': # obtain the request event from the 'POST' call event = request.json object_context = event["getObjectContext"] # Get the presigned URL to fetch the requested # original object from MinIO s3_url = object_context["inputS3Url"]
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.7K bytes - Viewed (0) -
impl/maven-core/src/main/resources/META-INF/maven/extension.xml
<!-- SLF4J --> <exportedPackage>org.slf4j.*</exportedPackage> <exportedPackage>org.slf4j.spi.*</exportedPackage> <exportedPackage>org.slf4j.helpers.*</exportedPackage> <exportedPackage>org.slf4j.event.*</exportedPackage> </exportedPackages> <exportedArtifacts> <!-- maven 4 api --> <exportedArtifact>org.apache.maven:maven-api-annotations</exportedArtifact>Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Mon Mar 24 14:07:06 UTC 2025 - 12.6K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/scope/WeakMojoExecutionListener.java
* @since 3.1.2 */ public interface WeakMojoExecutionListener { void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException; void afterMojoExecutionSuccess(MojoExecutionEvent event) throws MojoExecutionException; void afterExecutionFailure(MojoExecutionEvent event);Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java
static final Object EVENT = new Object(); abstract H createSubscriber(); private @Nullable H subscriber; H getSubscriber() { return subscriber; } @Override protected void setUp() throws Exception { subscriber = createSubscriber(); EventBus bus = new EventBus(); bus.register(subscriber); bus.post(EVENT); } @Override
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.6K bytes - Viewed (0) -
internal/config/lambda/parse.go
} } return targets, nil } // FetchEnabledTargets - Returns a set of configured TargetList func FetchEnabledTargets(ctx context.Context, cfg config.Config, transport *http.Transport) (*event.TargetList, error) { targetList := event.NewTargetList() for _, subSys := range config.LambdaSubSystems.ToSlice() { targets, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return nil, err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0)