diff --git a/stubs/twisted/internet/protocol.pyi b/stubs/twisted/internet/protocol.pyi
new file mode 100644
--- /dev/null
+++ b/stubs/twisted/internet/protocol.pyi
@@ -0,0 +1,138 @@
+# Stubs for twisted.internet.protocol (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from twisted.python import components
+from typing import Any, Optional
+
+class Factory:
+    protocol: Any = ...
+    numPorts: int = ...
+    noisy: bool = ...
+    @classmethod
+    def forProtocol(cls, protocol: Any, *args: Any, **kwargs: Any): ...
+    def logPrefix(self): ...
+    def doStart(self) -> None: ...
+    def doStop(self) -> None: ...
+    def startFactory(self) -> None: ...
+    def stopFactory(self) -> None: ...
+    def buildProtocol(self, addr: Any): ...
+
+class ClientFactory(Factory):
+    def startedConnecting(self, connector: Any) -> None: ...
+    def clientConnectionFailed(self, connector: Any, reason: Any) -> None: ...
+    def clientConnectionLost(self, connector: Any, reason: Any) -> None: ...
+
+class _InstanceFactory(ClientFactory):
+    noisy: bool = ...
+    pending: Any = ...
+    reactor: Any = ...
+    instance: Any = ...
+    deferred: Any = ...
+    def __init__(self, reactor: Any, instance: Any, deferred: Any) -> None: ...
+    def buildProtocol(self, addr: Any): ...
+    def clientConnectionFailed(self, connector: Any, reason: Any) -> None: ...
+    def fire(self, func: Any, value: Any) -> None: ...
+
+class ClientCreator:
+    reactor: Any = ...
+    protocolClass: Any = ...
+    args: Any = ...
+    kwargs: Any = ...
+    def __init__(self, reactor: Any, protocolClass: Any, *args: Any, **kwargs: Any) -> None: ...
+    def connectTCP(self, host: Any, port: Any, timeout: int = ..., bindAddress: Optional[Any] = ...): ...
+    def connectUNIX(self, address: Any, timeout: int = ..., checkPID: bool = ...): ...
+    def connectSSL(self, host: Any, port: Any, contextFactory: Any, timeout: int = ..., bindAddress: Optional[Any] = ...): ...
+
+class ReconnectingClientFactory(ClientFactory):
+    maxDelay: int = ...
+    initialDelay: float = ...
+    factor: float = ...
+    jitter: float = ...
+    delay: Any = ...
+    retries: int = ...
+    maxRetries: Any = ...
+    connector: Any = ...
+    clock: Any = ...
+    continueTrying: int = ...
+    def clientConnectionFailed(self, connector: Any, reason: Any) -> None: ...
+    def clientConnectionLost(self, connector: Any, unused_reason: Any) -> None: ...
+    def retry(self, connector: Optional[Any] = ...) -> None: ...
+    def stopTrying(self) -> None: ...
+    def resetDelay(self) -> None: ...
+
+class ServerFactory(Factory): ...
+
+class BaseProtocol:
+    connected: int = ...
+    transport: Any = ...
+    def makeConnection(self, transport: Any) -> None: ...
+    def connectionMade(self) -> None: ...
+
+connectionDone: Any
+
+class Protocol(BaseProtocol):
+    def logPrefix(self): ...
+    def dataReceived(self, data: Any) -> None: ...
+    def connectionLost(self, reason: Any) -> None: ...
+
+class ProtocolToConsumerAdapter(components.Adapter):
+    def write(self, data: Any) -> None: ...
+    def registerProducer(self, producer: Any, streaming: Any) -> None: ...
+    def unregisterProducer(self) -> None: ...
+
+class ConsumerToProtocolAdapter(components.Adapter):
+    def dataReceived(self, data: Any) -> None: ...
+    def connectionLost(self, reason: Any) -> None: ...
+    def makeConnection(self, transport: Any) -> None: ...
+    def connectionMade(self) -> None: ...
+
+class ProcessProtocol(BaseProtocol):
+    def childDataReceived(self, childFD: Any, data: Any) -> None: ...
+    def outReceived(self, data: Any) -> None: ...
+    def errReceived(self, data: Any) -> None: ...
+    def childConnectionLost(self, childFD: Any) -> None: ...
+    def inConnectionLost(self) -> None: ...
+    def outConnectionLost(self) -> None: ...
+    def errConnectionLost(self) -> None: ...
+    def processExited(self, reason: Any) -> None: ...
+    def processEnded(self, reason: Any) -> None: ...
+
+class AbstractDatagramProtocol:
+    transport: Any = ...
+    numPorts: int = ...
+    noisy: bool = ...
+    def doStart(self) -> None: ...
+    def doStop(self) -> None: ...
+    def startProtocol(self) -> None: ...
+    def stopProtocol(self) -> None: ...
+    def makeConnection(self, transport: Any) -> None: ...
+#    def datagramReceived(self, datagram: Any, addr: Any) -> None: ...
+
+class DatagramProtocol(AbstractDatagramProtocol):
+    def logPrefix(self): ...
+    def connectionRefused(self) -> None: ...
+
+class ConnectedDatagramProtocol(DatagramProtocol):
+#    def datagramReceived(self, datagram: Any) -> None: ...
+    def connectionFailed(self, failure: Any) -> None: ...
+
+class FileWrapper:
+    closed: int = ...
+    disconnecting: int = ...
+    producer: Any = ...
+    streamingProducer: int = ...
+    file: Any = ...
+    def __init__(self, file: Any) -> None: ...
+    def write(self, data: Any) -> None: ...
+    def registerProducer(self, producer: Any, streaming: Any) -> None: ...
+    def unregisterProducer(self) -> None: ...
+    def stopConsuming(self) -> None: ...
+    def writeSequence(self, iovec: Any) -> None: ...
+    def loseConnection(self) -> None: ...
+    def getPeer(self): ...
+    def getHost(self): ...
+    def handleException(self) -> None: ...
+    def resumeProducing(self) -> None: ...
+    def pauseProducing(self) -> None: ...
+    def stopProducing(self) -> None: ...