También podrías usar `from starlette.websockets import WebSocket`.

**FastAPI** proporciona el mismo `WebSocket` directamente solo como una conveniencia para ti, el desarrollador. Pero viene directamente de Starlette.

///

## Esperar mensajes y enviar mensajes { #await-for-messages-and-send-messages }

En tu ruta de WebSocket puedes `await` para recibir mensajes y enviar mensajes.

{* ../../docs_src/websockets/tutorial001_py39.py hl[48:52] *}

        assertNotNull(WitnessRegistration.WitnessRegistrationState.UNREGISTERING);
        assertNotNull(WitnessRegistration.WitnessRegistrationState.FAILED);
        assertNotNull(WitnessRegistration.WitnessRegistrationState.EXPIRED);
    }

    @Test
    void testEnumToStringConversions() {
        // Test that enum toString methods work properly
        assertEquals("CLUSTER_WITNESS", WitnessServiceType.CLUSTER_WITNESS.toString());

# Field name for click count in the index.
index.field.click_count=click_count
# Field name for config ID in the index.
index.field.config_id=config_id
# Field name for expiration date in the index.
index.field.expires=expires
# Field name for URL in the index.
index.field.url=url
# Field name for document ID in the index.
index.field.doc_id=doc_id
# Field name for internal ID in the index.
index.field.id=_id

    // initial capacity / concurrency level
    assertThat(map.segments[0].table.length()).isEqualTo(16 / map.segments.length);

    assertThat(map.evictsBySize()).isFalse();
    assertThat(map.expires()).isFalse();
    assertThat(map.expiresAfterWrite()).isFalse();
    assertThat(map.expiresAfterAccess()).isFalse();
    assertThat(map.refreshes()).isFalse();
  }

  public void testSetKeyEquivalence() {

    // initial capacity / concurrency level
    assertThat(map.segments[0].table.length()).isEqualTo(16 / map.segments.length);

    assertThat(map.evictsBySize()).isFalse();
    assertThat(map.expires()).isFalse();
    assertThat(map.expiresAfterWrite()).isFalse();
    assertThat(map.expiresAfterAccess()).isFalse();
    assertThat(map.refreshes()).isFalse();
  }

  public void testSetKeyEquivalence() {

      },
      "created": {
        "type": "date",
        "format": "date_optional_time"
      },
      "timestamp": {
        "type": "date",
        "format": "date_optional_time"
      },
      "expires": {
        "type": "date",
        "format": "date_optional_time"
      },
      "digest": {
        "type": "text",
        "index": false
      },
      "doc_id": {
        "type": "keyword"

	if err != nil {
		return err
	}

	if days < 0 {
		return errTransitionInvalidDays
	}
	*tDays = TransitionDays(days)

	return nil
}

// MarshalXML encodes number of days to expire if it is non-zero and
// encodes empty string otherwise
func (tDays TransitionDays) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
	return e.EncodeElement(int(tDays), startElement)
}

labels.incrementalCrawling=Vérifier la dernière modification
labels.errorCount=Nombre d'erreurs
labels.errorLog=Journal des erreurs
labels.errorName=Nom de l'erreur
labels.expiredTime=Date d'expiration
labels.expires=Expire
labels.failureCountThreshold=Seuil de nombre d'échecs
labels.fileConfigName=Nom de la configuration d'exploration de fichiers
labels.fileName=Nom de fichier
labels.handlerName=Nom du gestionnaire

///

## Aguarde mensagens e envie mensagens { #await-for-messages-and-send-messages }

Em sua rota WebSocket você pode esperar (`await`) por mensagens e enviar mensagens.

{* ../../docs_src/websockets/tutorial001_py39.py hl[48:52] *}

Você pode receber e enviar dados binários, de texto e JSON.

## Tente { #try-it }

                // This is a duplicate check, as preWriteCleanup already purged expired
                // entries, but let's accommodate an incorrect expiration queue.
                enqueueNotification(
                    entryKey, hash, value, valueReference.getWeight(), RemovalCause.EXPIRED);
              } else {
                recordLockedRead(e, now);
                statsCounter.recordHits(1);